Details
-
Bug
-
Resolution: Done
-
Blocker
-
None
-
None
-
False
-
False
-
Version 1.4 and 1.5(dev)
-
Undefined
-
Description
I am unable to configure a MySqlConnectorTask. The logs state that two properties, both related to Kafka, are missing or invalid. The documentation in version 1.4 and 1.5 do not list these as required parameters.
database.history.kafka.bootstrap.servers' value is invalid: A value is required database.history.kafka.topic' value is invalid: A value is required
Configuration
debezium.sink.type=kinesis debezium.sink.kinesis.region=us-east-1 debezium.source.connector.class=io.debezium.connector.mysql.MySqlConnector debezium.source.offset.storage.file.filename=data/offsets.dat debezium.source.offset.flush.interval.ms=0 debezium.source.database.hostname=localhost debezium.source.database.port=3306 debezium.source.database.user=cdcuser debezium.source.database.password=password debezium.source.database.dbname=cdctest debezium.source.database.server.name=tutorial debezium.source.schema.include.list=cdctest
Logs
2021-03-25 13:42:46,634 ERROR [io.deb.con.com.BaseSourceTask] (pool-3-thread-1) The 'database.history.kafka.bootstrap.servers' value is invalid: A value is required
2021-03-25 13:42:46,634 ERROR [io.deb.con.com.BaseSourceTask] (pool-3-thread-1) The 'database.history.kafka.topic' value is invalid: A value is required
2021-03-25 13:42:46,638 INFO [io.deb.ser.ConnectorLifecycle] (pool-3-thread-1) Connector completed: success = 'false', message = 'Unable to initialize and start connector's task class 'io.debezium.connector.mysql.MySqlConnectorTask' with config:
{connector.class=io.debezium.connector.mysql.MySqlConnector, offset.flush.interval.ms=0, database.user=root, database.dbname=cdctest, offset.storage.file.filename=data/offsets.dat, database.hostname=localhost, database.password=********, name=kinesis, schema.include.list=cdctest, database.server.name=cdctest, database.port=3306}', error = '{}': org.apache.kafka.connect.errors.ConnectException: Error configuring an instance of MySqlConnectorTask; check the logs for details
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:120)
at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:759)
at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:181)
at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:142)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)