Spring-Kafka 1.3.9与Kafka客户端0.10.2.2不兼容
https://spring.io/projects/spring-kafka指出，“所有brokers>=0.10.x.x的用户（以及所有spring boot 1.5.x用户）建议使用spring-kafka 1.3.x或更高版本”我已经在pom.xml中设置了spring-kafka 1.3.9版本，并将Kafka客户端从0.11.x.x覆盖到0.10.2.2
当我运行实例时，我会出现以下错误：
由：java.lang.noClassDefFounderRorr：org/apache/kafka/common/headers/headers at org.springframework.kafka.core.kafkatemplate.(kafkatemplate.java:74)~[spring-kafka-1.3.9.release.jar:？]
共有1个答案
-
我无法让Spring-Kafka与Kafka客户端版本1.x一起工作。当我使用更高的kafka客户机(>2)时，我得到以下错误 [使用者Clientid=Adapter1-0,GroupID=XXXX]无法建立到节点-1的连接。代理可能不可用。 我无法找出是Spring问题还是KAfka客户端版本问题
-
我的设置： JDK 11.0.6 Spring护套2.2.4.释放 Springkafka 2.4.1 我已经在PLAINTEXT中验证了我的Zookeeper/Kafka/client应用程序，一切正常。我还用Kafka客户端工具验证了我的密钥库/信任库。 我正在使用KafkaAdmin bean配置我的主题，它似乎在SSL连接上失败了: 我的两个JKS文件位于项目的src/main/resou
-
问题内容： 建筑： 我们有一个使用2个pubsub主题/订阅对的架构： 定期由cronjob触发主题（例如，每5分钟触发一次）。订阅是我们云功能的触发器。 主题充当我们的一项服务发布的后台作业的队列。云功能在每次执行时读取订阅，以为排队的后台作业提供服务。 这使我们可以控制后台作业的服务频率，而与将它们添加到队列的时间无关。 云功能（由触发）通过pull读取消息。它决定准备好哪些后台作业，并在成功
-
这个链接说：Apache Kafka 0.9.0.1 http://docs.spring.io/spring-kafka/docs/1.1.3.build-snapshot/reference/html/_integrate.html
-
执行kafka客户端的生产者/消费者连接池有意义吗？ kafka是否在内部维护已初始化并准备好使用的连接对象列表？ 我们希望最小化连接创建的时间，这样在发送/接收消息时就不会有额外的开销。 目前，我们正在使用apache共享池库来保持连接。 任何帮助都将不胜感激。
-
我使用的是kafka-clients-0.10.1.1（单节点单代理） auto.create.topics.enable的默认值为true。 1.我正在使用以下方式向主题发送消息： 用于消费：