Совместимость версий Кафки, Spring Cloud Stream и Spring Cloud Stream Binder Kafka - PullRequest
Новая
       12

Совместимость версий Кафки, Spring Cloud Stream и Spring Cloud Stream Binder Kafka

0 голосов
/ 08 января 2019

Я использую Kafka-client версию 1.0.0 и Spring-cloud-stream версию 2.0.2. теперь я хочу знать версию 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: предоставление исключения; вложенным исключением является java.util.concurrent.TimeoutException headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в 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 | в org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.provisionProducerDestination (KafkaTopicProvisioner.java:131) ~ [spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar! /: .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_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в 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 | в org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.doBindProducer (AbstractMessageChannelBinder.java:77) ~ [spring-cloud-stream-2.0.2.RELEASE.jar! /: 2.0.2.RELEASE] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в 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 | в org.springframework.cloud.stream.binding.BindingService.lambda $ rescheduleProducerBinding $ 2 (BindingService.java:262) ~ [spring-cloud-stream-2.0.2.RELEASE.jar! /: 2.0.2.RELEASE] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в 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 | в java.base / java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:515) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в java.base / java.util.concurrent.FutureTask.run (FutureTask.java:264) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в java.base / java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:304) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в java.base / java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1128) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в java.base / java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:628) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в java.base / java.lang.Thread.run (Thread.java:834) ~ [na: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | Вызвано: java.util.concurrent.TimeoutException: null headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | at org.apache.kafka.common.internals.KafkaFutureImpl $ SingleWaiter.await (KafkaFutureImpl.java:108) ~ [kafka-clients-1.0.1.jar! /: na]headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | на org.apache.kafka.common.internals.KafkaFutureImpl.get (KafkaFutureImpl.java:225) ~ [kafka-clients-1.0.1.jar! /: na] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicAndPartitions (KafkaTopicProvisioner.java:288) ~ [spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar! .0.RELEASE] headless_api-gateway-service.1.te0u82ql4pkh@node8.docker.com | в org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner.createTopicIfNeeded (KafkaTopicProvisioner.java:268) ~ [spring-cloud-stream-binder-kafka-core-2.0.0.RELEASE.jar! .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 общих кадров пропущено

1 Ответ

0 голосов
/ 08 января 2019

См. Страницу проекта Spring для Apache Kafka , где приведена матрица совместимости.

В настоящее время

enter image description here

Однако, как сказал Олег в удаленном ответе, тайм-аут, скорее всего, является неправильной конфигурацией (например, несовпадающий SSL). Включите ведение журнала DEBUG, чтобы узнать, предоставляет ли он дополнительную информацию.

...