TOP

kafka报错(三):Failed to construct kafka consumer
2018-11-30 10:49:14 】 浏览:2415
Tags:kafka 报错 Failed construct consumer

版权声明:本博客所有文章均为原创,如有转载,请注明原文地址,谢谢!----桃花惜春风 https://blog.csdn.net/xiaoyu_BD/article/details/82464606

错误日志:

Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
    at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:793)
    at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:644)
    at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:624)
    at com.unigroup.consumer.CanalConsumer.init(CanalConsumer.java:29)
    at com.unigroup.starup.test.main(test.java:22)
Caused by: org.apache.kafka.common.KafkaException: org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.serialization.Deserializer
    at org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:304)
    at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:688)
    ... 4 more

这里从报错来看很明显了
producer: org.apache.kafka.common.serialization.StringSerializer
consumer:org.apache.kafka.common.serialization.StringDeserializer
一个是序列化一个是反序列化,两个并不一样。查看配置文件。

确认API版本号与安装包版本号是否一致:
如果安装的是kafka,直接查看libs目录下的jar版本就知道kafka版本了。
如果安装的是confluent,查看kafka版本号方式可以关注私信我。

更多:kafka深入理解专栏
——————————————————————————————————
作者:桃花惜春风
转载请标明出处,原文地址:
https://blog.csdn.net/xiaoyu_BD/article/details/82464606
如果感觉本文对您有帮助,您的支持是我坚持写作最大的动力,谢谢!


kafka报错(三):Failed to construct kafka consumer https://www.cppentry.com/bencandy.php?fid=120&id=192300

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇kafka接口操作topic 下一篇kafka JAVA API解析