错误日志：

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
如果感觉本文对您有帮助，您的支持是我坚持写作最大的动力，谢谢！