Debezium connector cannot create topic

Kafka Connect Self-Managed Connectors
1

Dear all, I created debezium source connector to my PostgreSQL server

CREATE SOURCE CONNECTOR `SR-PG-Debezium` WITH(
  "connector.class"				= 'io.debezium.connector.postgresql.PostgresConnector',
  "plugin.name"					= 'pgoutput',
  "database.hostname"				= '192.168.219.152', 
  "database.port"				= '5432', 
  "database.user"				= 'kafka', 
  "database.password"				= 'password', 
  "database.dbname" 				= 'kafka', 
  "database.server.name"			= 'postgres', 
  "table.include.list"				= 'kafka.mqtt_table',
  "topic.creation.enable"			= 'true',
  "topic.creation.default.replication.factor"	= '1',  
  "topic.creation.default.partitions"		= '10',  
  "topic.creation.default.cleanup.policy"	= 'compact',  
  "topic.creation.default.compression.type"	= 'lz4');

The connector successfully created and RUNNING but not creating the TOPIC - why? Could you somebody help me pls?

2

check the worker logs, you will get your answer there…

1 Like
3

This topic was automatically closed after 30 days. New replies are no longer allowed.