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

org.apache.flink.kafka.shaded.org.apache.kafka.com

org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. 创建了一个kafka表,topic不存在,produer时提示这个错误,请问需要配置什么参数?我kafka已经开启自动创建topic了

展开
收起
游客3oewgrzrf6o5c 2022-07-28 13:44:59 559 0
1 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    这个错误提示说明你的Flink程序尝试连接到Kafka集群,但是找不到指定的Topic。这可能是因为Kafka集群中确实不存在该Topic,或者Flink程序连接的Kafka集群与实际运行的Kafka集群不一致。

    首先,你需要确认一下以下几点:

    1. 你是否在Kafka中创建了对应的Topic。你可以使用Kafka自带的命令行工具来查看Topic列表,例如:bin/kafka-topics.sh --list

    2. 你是否在Flink程序中正确地配置了Kafka的连接参数。你需要确保以下参数都设置正确:

      • bootstrap.servers:这是Kafka集群的地址,格式为"host1:port1,host2:port2",多个地址用逗号分隔。
      • group.id:这是消费者组的ID,所有消费者共享同一个消费者组。
    3. 如果你的Kafka集群启用了自动创建Topic的功能,那么可能是Flink程序连接的Kafka集群与实际运行的Kafka集群不一致。你需要检查并确认你的Flink程序连接的是正确的Kafka集群。

    如果以上都没有问题,但仍然出现这个错误,那么可能是由于网络问题导致的。你可以尝试增加连接超时时间,或者检查网络连接是否正常。

    2023-07-16 07:58:40
    赞同 展开评论 打赏

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

相关电子书

更多
Apache Spark – Apache HBase Connector 立即下载
Apache Flink 必知必会 立即下载
Apache Ignite and Apache Spark 立即下载