无法将弹簧应用程序连接到 debezium kafka

Question

我正在尝试将我的弹簧应用程序连接到debezium/kafka：0.10，但没有成功。最初该应用程序使用wurstmeister/kafka图像，但现在我正在引入debezium的新功能，并且只想对两者使用一个kafka图像。我无法将应用程序连接到debezium kafka或debezium连接到wurstmeister kafka。有人知道是否可以同时使用一个图像吗？欢迎任何想法:)

问题是应用程序无法将主题创建到 debezium 容器中。而且debezium也无法与wurstmeister kafka图像一起使用。

错误 18864 --- [ main] o.springframework.kafka.core.KafkaAdmin ： 无法配置主题 org.springframework.kafka.KafkaException：等待获取现有主题超时;嵌套异常是java.util.concurrent.TimeoutException。 at org.springframework.kafka.core.KafkaAdmin.lambda$checkPartitions$2(KafkaAdmin.java：235( ~[spring-kafka-2.2.3.RELEASE.jar：2.2.3.RELEASE] at java.base/java.util.HashMap.forEach(HashMap.java：1336( ~[na：na]

services： 动物园管理员： 图片：Debezium/Zookeeper：0.10 港口： - 2181:2181 - 2888:2888 - 3888:3888 卡 夫 卡： 图片：Debezium/Kafka：0.10 港口： - 9092:9092 链接： - 动物园管理员 环境： - ZOOKEEPER_CONNECT=动物园管理员：2181 - ADVERTISED_HOST_NAME=10.0.75.1 连接： 图片：脱贝齐姆/连接：0.10 港口： - 8083:8083 链接： -卡 夫 卡 - MySQL 环境： - BOOTSTRAP_SERVERS=卡夫卡：9092 - GROUP_ID=1 - CONFIG_STORAGE_TOPIC=my_connect_configs - OFFSET_STORAGE_TOPIC=my_connect_offsets - STATUS_STORAGE_TOPIC=my_connect_statuses

Answer 1

除了ADVERTISED_HOST_NAME，还需要向容器环境添加ADVERTISED_LISTENERS。

ADVERTISED_LISTENERS - 经纪人将在 zookeeper 中注册此值，当外部世界想要连接到您的 Kafka 集群时，他们可以通过您在ADVERTISED_LISTENERS属性中提供的网络连接。

例：

environment:
- ADVERTISED_HOST_NAME=<Host IP>
- ADVERTISED_LISTENERS=PLAINTEXT://<Host IP>:9092