kafka、Spring Cloud stream、Spring cloud stream绑定器kafka的版本兼容性

Question

我使用的是1.0.0的Kafka-client版本和2.0.2的Spring-cloud-stream版本。现在我想知道Spring-cloud-stream-binder-kafka的版本，以便将事件流式传输到kafka。

创建生产者绑定失败，30秒内重试headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | org.springframework.cloud.stream.provisioning.ProvisioningException:配置异常；嵌套异常is java.util.concurrent.TimeoutException headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopic(KafkaTopicProvisioner.java:259) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:131) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com |在org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination(KafkaTopicProvisioner.java:74) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_spring| at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:149) ~spring-cloud-stream-2.0.2.RELEASE.jar!/:2.0.2.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer(AbstractMessageChannelBinder.java:77) ~ api-gateway-service.1.te0u82ql4pkh@node8.docker.com -cloud-stream-2.0.2.RELEASE.jar！spring headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.AbstractBinder.bindProducer(AbstractBinder.java:138) ~spring-cloud-stream-2.0.2.RELEASE.jar!/:2.0.2.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binding.BindingService.lambda$rescheduleProducerBinding$2(BindingService.java:262) ~/:2.0.2.RELEASE-cloud- headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com -2.0.2.RELEASE.jar！at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~spring-context-5.0.7.RELEASE.jar!/:5.0.7.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors的/:2.0.2.RELEASE流headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com ) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com| at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at java.base/java.lang.Thread.run(Thread.java:834) ~na:na headless_api-gateway-service.1.te0u82ql4pkh@node8.客户端|由: org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:108) ~kafka- headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com -1.0.1.jar！docker.com headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:225) ~kafka-headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com-1处的java.util.concurrent.TimeoutException:空客户端|引起。0.1.jar！headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicAndPartitions(KafkaTopicProvisioner.java:288) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.springframework.cloud.stream.binder.kafka.provisioning. /:naKafkaTopicProvisioner.createTopicIfNecessary(KafkaTopicProvisioner.java:268) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com |在org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopic(KafkaTopicProvisioner.java:252) ~spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar!/:2.0.0.RELEASE headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | ... 13个常用帧被省略

Answer 1

有关兼容性列表，请参阅Spring for Apache Kafka project page。

目前

​

​

然而，正如奥列格在删除的答案中所说，超时更有可能是配置错误(例如，SSL不匹配)。打开调试日志记录，查看它是否提供了更多信息。