fix

docker-compose-debezium.yml

@@ -2,7 +2,7 @@ version: '3.9'
 
 services:
 
-  zookeeper:
+  zookeeper-sync:
     image: 47.110.145.204:8084/huansiyl/debezium/zookeeper:1.9.5.Final
     ports:
       - "2181:2181"
@@ -10,20 +10,24 @@ services:
       - "3888:3888"
     restart: always
 
-  kafka:
+  kafka-sync:
     image: 47.110.145.204:8084/huansiyl/debezium/kafka:1.9.5.Final
     restart: always
     ports:
-      - "9092:9092"
+      - "9092"
       - "29092:29092"
     depends_on:
-      - zookeeper
+      - zookeeper-sync
     environment:
-      - ZOOKEEPER_CONNECT=zookeeper:2181
-      - KAFKA_ADVERTISED_LISTENERS=LISTENER_EXT://localhost:29092,LISTENER_INT://kafka:9092
+      - ZOOKEEPER_CONNECT=zookeeper-sync:2181
+      - KAFKA_ADVERTISED_LISTENERS=LISTENER_EXT://localhost:29092,LISTENER_INT://kafka-sync:9092
       - KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=LISTENER_INT:PLAINTEXT,LISTENER_EXT:PLAINTEXT
       - KAFKA_LISTENERS=LISTENER_INT://0.0.0.0:9092,LISTENER_EXT://0.0.0.0:29092
       - KAFKA_INTER_BROKER_LISTENER_NAME=LISTENER_INT
+      - KAFKA_LOG_RETENTION_BYTES=1073741824
+      - KAFKA_LOG_SEGMENT_BYTES=268435456
+      - KAFKA_LOG_RETENTION_MS=300000
+      - KAFKA_LOG_CLEANUP_POLICY=delete
 
   connect:
     image: 47.110.145.204:8084/huansiyl/debezium/connect:1.9.5.Final
@@ -31,11 +35,11 @@ services:
     ports:
       - "8083:8083"
     environment:
-      - BOOTSTRAP_SERVERS=kafka:9092
+      - BOOTSTRAP_SERVERS=kafka-sync:9092
       - GROUP_ID=1
       - CONFIG_STORAGE_TOPIC=my_connect_configs
       - OFFSET_STORAGE_TOPIC=my_connect_offsets
       - STATUS_STORAGE_TOPIC=my_connect_statuses
     depends_on:
-      - zookeeper
-      - kafka
\ No newline at end of file
+      - zookeeper-sync
+      - kafka-sync
\ No newline at end of file

docker-compose.kafka.yml

@@ -17,6 +17,15 @@
 version: '2.2'
 
 services:
+  kafka:
+    restart: always
+    image: "bitnami/kafka:3.2.0"
+    ports:
+      - "9092:9092"
+    env_file:
+      - kafka.env
+    depends_on:
+      - zookeeper
   tb-js-executor:
     env_file:
       - queue-kafka.env

docker-compose.yml

@@ -18,6 +18,15 @@
 version: '2.2'
 
 services:
+  zookeeper:
+    restart: always
+    image: "zookeeper:3.8.0"
+    ports:
+      - "2181"
+    environment:
+      ZOO_MY_ID: 1
+      ZOO_SERVERS: server.1=zookeeper:2888:3888;zookeeper:2181
+      ZOO_ADMINSERVER_ENABLED: "false"
   tb-js-executor:
     restart: always
     image: "${DOCKER_REPO}/${JS_EXECUTOR_DOCKER_NAME}:${TB_VERSION}"