确保在类路径上有org.apache.kafka:kafka-clients以及org.apache.kafka:kafka。像Maven这样的工具应该为你做这个,但也许你手动处理依赖?如果是这样,您将需要在此处比较依赖项 https://mvnrepository.com/artifact/org.apache.kafka/kafka_2.11/0.8.2.1 到这里设置的新依赖项 https://mvnrepository.com/artifact/org.apache.kafka/kafka_2.11/0.11.0.1
我遇到了同样的问题,经过几天(!)后,我终于找到了一个我想与你分享的解决方案
问题是项目的eclipse引用库中的kafka-clients包的版本。尽管使用了maven更新,它保留了0.8.2.1版本。但正确的是0.10.2.1。所以,我从maven导入了正确的库
mvn dependency:get -Dartifact=org.apache.kafka:kafka-clients:0.10.2.1
并从类路径中删除旧版本,它的工作原理! 希望这可以帮助 ! 米歇尔。