当我使用启动 Debezium 连接器用于 PostgreSQL 时,未创建 Kafka 主题。这是我的属性文件中的内容:
name=testdb
connector.class=io.debezium.connector.postgresql.PostgresConnector
topic.prefix=test
database.hostname=localhost
database.port=5432
database.user=postgres
database.password=root
database.dbname=testdb
database.server.name=testdb
table.include.list=ipaddrs
plugin.name=pgoutput
根据this,主题应该命名testdb.myschema.ipaddrs
(myschema
是我的架构的名称)。然而bin/kafka-topics.sh --list --bootstrap-server 192.168.56.1:9092
什么也不返回。如果我向表添加行,则不会创建主题ipaddrs
.
当我运行时,Kafka 连接成功启动bin/connect-standalone.sh config/connect-standalone.properties config/postgres.properties
无一例外。
I have auto.create.topics.enable = true
. http://localhost:8083/connectors/testdb/status
显示这个:
{"name":"testdb","connector":{"state":"RUNNING","worker_id":"10.0.0.48:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"10.0.0.48:8083"}],"type":"source"}
我没有运行 Zookeeper。我正在使用 KRaft 运行 Kafka。