开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的之外,还有其他参数吗?

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的这四个字的之外,还有其他的必要参数嘛?:
CREATE TEMPORARY TABLE source_table (
mess varbinary
) WITH (
'connector' = 'mq5',
'endpoint' = '',
'topic' = 'mq-test',
'consumerGroup' = 'mq-group'
);
我在创建链接的时候报了如下的错误:
Details: com.ververica.platform.engine.api.exception.SqlEngineException: org.apache.flink.table.sqlserver.api.utils.FlinkSQLException: java.lang.RuntimeException: Failed to fetch next result
Caused by: com.alibaba.ververica.connectors.mq5.shaded.org.apache.rocketmq.client.exception.MQClientException: CODE: 16 DESC: username cannot be null.

展开
收起
三分钟热度的鱼 2024-07-10 23:42:47 49 0
1 条回答
写回答
取消 提交回答

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载