Не удается подключить приложение весны к debezium kafka - PullRequest
Новая
       49

Не удается подключить приложение весны к debezium kafka

0 голосов
/ 20 сентября 2019

Я пытаюсь подключить свое весеннее приложение к дебезиуму / кафке: 0.10, но безуспешно.Первоначально приложение использовало образ wurstmeister / kafka, но теперь я представляю новую функциональность с debezium и хочу использовать только одно изображение kafka для обоих.Я не могу подключить ни приложение к debezium kafka, ни debezium к wurstmeister kafka.Кто-нибудь знает, возможно ли использовать только одно изображение для обоих?Любые идеи приветствуются:)

Проблема в том, что приложение не может создать тему в контейнере debezium.А также дебезиум не умеет работать с образом wurstmeister kafka. 

ERROR 18864 --- [           main] o.springframework.kafka.core.KafkaAdmin  : Could not configure topics

org.springframework.kafka.KafkaException: Timed out waiting to get existing topics; nested exception is 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:
  zookeeper:
    image: debezium/zookeeper:0.10
    ports:
      - 2181:2181
      - 2888:2888
      - 3888:3888
  kafka:
    image: debezium/kafka:0.10
    ports:
      - 9092:9092
    links:
      - zookeeper
    environment:
      - ZOOKEEPER_CONNECT=zookeeper:2181
      - ADVERTISED_HOST_NAME=10.0.75.1
  connect:
    image: debezium/connect:0.10
    ports:
      - 8083:8083
    links:
      - kafka
      - mysql
    environment:
      - BOOTSTRAP_SERVERS=kafka:9092
      - GROUP_ID=1
      - CONFIG_STORAGE_TOPIC=my_connect_configs
      - OFFSET_STORAGE_TOPIC=my_connect_offsets
      - STATUS_STORAGE_TOPIC=my_connect_statuses
...