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

Flink CDC报错?

Flink CDC报错? WARN (org.apache.kafka.clients.consumer.ConsumerConfig:logUnused) - The configuration 'partition.discovery.interval.ms' was supplied but isn't a known config.

展开
收起
真的很搞笑 2023-11-22 09:10:14 49 0
4 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    WARN (org.apache.kafka.clients.consumer.ConsumerConfig:logUnused)这个错误表示您指定了一个未识别的配置项。
    通常,这个错误表示您正在使用的配置文件中含有未知配置项。如果遇到了这个错误,请检查您的配置文件,并确保所有指定的配置项都是有效的。您可以检查Flink CDC文档以了解支持哪些配置项。
    另外,请注意,这个警告不影响任务的运行,只是表示这个配置项无效。您可以忽略这个警告,但是如果想解决它,请修改配置文件。

    2023-11-29 13:52:14
    赞同 展开评论 打赏
  • 这个警告信息表示在Flink CDC的配置中,提供了一个名为'partition.discovery.interval.ms'的参数,但是这个参数并不是Kafka消费者配置中的一个已知参数。你可以尝试删除这个参数,或者检查你的Flink CDC和Kafka版本是否兼容。

    2023-11-29 12:01:26
    赞同 展开评论 打赏
  • 0357ecee99ca9e77678cd16bca2950df.png
    这个参数都不对,是不是需要排除下两种对不上,此回答整理自钉群“Flink CDC 社区”

    2023-11-22 12:06:13
    赞同 展开评论 打赏
  • 此报错可能是由于您尝试使用未识别的配置参数 partition.discovery.interval.ms 引起的。根据 FLINK CDC 文档,该参数并不受支持。可以参考官网文档进行参数配置,并确保所有参数都是有效的。建议您使用其他的参数来配置分区发现间隔。

    2023-11-22 11:06:20
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载