diff --git a/labs/doris/conf/debezium/register-mysql.json b/labs/doris/conf/debezium/register-mysql.json index fb11fdc2..7752d76f 100644 --- a/labs/doris/conf/debezium/register-mysql.json +++ b/labs/doris/conf/debezium/register-mysql.json @@ -8,10 +8,10 @@ "database.user": "slave", "database.password": "aA123456!", "database.server.id": "1", - "database.server.name": "server1", + "database.server.name": "mysql", "database.include": "example", "database.history.kafka.bootstrap.servers": "kafka:9092", - "database.history.kafka.topic": "schema-changes.example", + "database.history.kafka.topic": "schema.example", "include.schema.changes": "true" } } \ No newline at end of file diff --git a/labs/doris/docker-compose.yml b/labs/doris/docker-compose.yml index 35190047..d6417071 100644 --- a/labs/doris/docker-compose.yml +++ b/labs/doris/docker-compose.yml @@ -17,6 +17,7 @@ services: restart: always ports: - 2181:2181 + #/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mysql-server.example.User kafka: image: wurstmeister/kafka:2.13-2.7.0 restart: always @@ -82,6 +83,7 @@ services: - canal.instance.tsdb.enable=true depends_on: - mysql + command: bash -c "run.sh" doris-be: image: primetoninc/jdk:1.8 ports: