-
Bug
-
Resolution: Obsolete
-
Major
-
None
-
False
-
-
False
In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.
Bug report
For bug reports, provide this information, please:
What Debezium connector do you use and what version?
2.7.1.Final-mysql connect
What is the connector configuration?
apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: mysql-connector-orders namespace: kafka-prod labels: strimzi.io/cluster: kafka-connect-prod spec: class: io.debezium.connector.mysql.MySqlConnector tasksMax: 1 config: tasks.max: 1 database.hostname: orders-db.prod.internal database.port: 3306 database.user: debezium_user database.password: ${secrets:kafka-prod/mysql-credentials:password} database.server.id: 10001 topic.prefix: mysql database.include.list: orders_db table.include.list: orders_db.* schema.history.internal.kafka.bootstrap.servers: kafka-bootstrap:9092 schema.history.internal.kafka.topic: schema-changes.mysql.orders snapshot.mode: schema_only snapshot.locking.mode: none value.converter: org.apache.kafka.connect.json.JsonConverter value.converter.schemas.enable: false key.converter: org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable: false This connector status keeps showing RUNNING with HTTP 200, but no CDC data is produced. Recovery Attempt (Example) We created a new connector with a new name and server ID and tried to start from the last known binlog position: apiVersion: kafka.strimzi.io/v1beta2 kind: KafkaConnector metadata: name: mysql-connector-orders-recovery namespace: kafka-prod labels: strimzi.io/cluster: kafka-connect-prod spec: class: io.debezium.connector.mysql.MySqlConnector tasksMax: 1 config: tasks.max: 1 database.hostname: orders-db.prod.internal database.port: 3306 database.user: debezium_user database.password: ${secrets:kafka-prod/mysql-credentials:password} database.server.id: 10002 topic.prefix: mysql database.include.list: orders_db table.include.list: orders_db.* schema.history.internal.kafka.bootstrap.servers: kafka-bootstrap:9092 schema.history.internal.kafka.topic: schema-changes.mysql.orders database.initial.binlog.filename: mysql-bin-changelog.012345 database.initial.binlog.position: 1234567 snapshot.mode: schema_only snapshot.locking.mode: none value.converter: org.apache.kafka.connect.json.JsonConverter value.converter.schemas.enable: false key.converter: org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable: false But even with the binlog filename and position, it does not resume correctly.
What is the captured database version and mode of deployment?
We have deployed kafka on eks using strimzi and running mysql-connect on eks.
Do you have the connector logs, ideally from start till finish?
Connector logs are not showing any error and showing status 200 when we are checking connector status.