Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2019-07-24 07:26:35,453 INFO || 127.0.0.1 - - [24/Jul/2019:07:26:35 +0000] "GET /connectors HTTP/1.1" 200 22 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:26:35,506 INFO || 127.0.0.1 - - [24/Jul/2019:07:26:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:26:35,560 INFO || 127.0.0.1 - - [24/Jul/2019:07:26:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:26:58,298 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:26:58,298 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:26:58,388 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 90 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:28,388 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:28,389 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:28,452 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 63 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:35,462 INFO || 127.0.0.1 - - [24/Jul/2019:07:27:35 +0000] "GET /connectors HTTP/1.1" 200 22 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:27:35,512 INFO || 127.0.0.1 - - [24/Jul/2019:07:27:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:27:35,564 INFO || 127.0.0.1 - - [24/Jul/2019:07:27:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:27:58,452 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:58,452 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:27:58,513 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 61 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:28,514 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:28,514 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:28,577 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 63 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:35,466 INFO || 127.0.0.1 - - [24/Jul/2019:07:28:35 +0000] "GET /connectors HTTP/1.1" 200 22 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:28:35,516 INFO || 127.0.0.1 - - [24/Jul/2019:07:28:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:28:35,573 INFO || 127.0.0.1 - - [24/Jul/2019:07:28:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:28:58,578 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:58,578 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:28:58,643 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 65 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:08,661 ERROR MySQL|cdc-source-myschema-mytable|binlog Error during binlog processing. Last offset stored = null, binlog reader near position = mysql-bin.000110/821128429 [io.debezium.connector.mysql.BinlogReader]
- 2019-07-24 07:29:08,661 ERROR MySQL|cdc-source-myschema-mytable|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader]
- org.apache.kafka.connect.errors.ConnectException: Error recording the DDL statement(s) in the database history Kafka topic cdc-history-myschema-mytable:0 using brokers at null: ALTER TABLE supplier_settings DROP mlg_delivery
- at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)
- at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:486)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)
- at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)
- at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)
- at java.lang.Thread.run(Thread.java:748)
- Caused by: org.apache.kafka.connect.errors.ConnectException: Error recording the DDL statement(s) in the database history Kafka topic cdc-history-myschema-mytable:0 using brokers at null: ALTER TABLE supplier_settings DROP mlg_delivery
- at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:360)
- at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:672)
- at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:470)
- ... 5 more
- Caused by: java.lang.IllegalStateException: No producer is available. Ensure that 'start()' is called before storing database history records.
- at io.debezium.relational.history.KafkaDatabaseHistory.storeRecord(KafkaDatabaseHistory.java:178)
- at io.debezium.relational.history.AbstractDatabaseHistory.record(AbstractDatabaseHistory.java:66)
- at io.debezium.relational.history.AbstractDatabaseHistory.record(AbstractDatabaseHistory.java:60)
- at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:355)
- ... 7 more
- 2019-07-24 07:29:08,662 INFO MySQL|cdc-source-myschema-mytable|binlog Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. [io.debezium.connector.mysql.BinlogReader]
- 2019-07-24 07:29:28,643 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:28,644 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:28,722 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 78 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:35,457 INFO || 127.0.0.1 - - [24/Jul/2019:07:29:35 +0000] "GET /connectors HTTP/1.1" 200 22 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:29:35,504 INFO || 127.0.0.1 - - [24/Jul/2019:07:29:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:29:35,552 INFO || 127.0.0.1 - - [24/Jul/2019:07:29:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:29:58,723 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:58,723 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:29:58,813 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 90 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:30:28,813 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:30:28,814 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:30:28,889 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 75 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:30:35,466 INFO || 127.0.0.1 - - [24/Jul/2019:07:30:35 +0000] "GET /connectors HTTP/1.1" 200 22 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:30:35,519 INFO || 127.0.0.1 - - [24/Jul/2019:07:30:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:30:35,573 INFO || 127.0.0.1 - - [24/Jul/2019:07:30:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 1 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:30:58,890 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:30:58,890 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:28,890 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:28,890 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:28,953 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 62 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:35,467 INFO || 127.0.0.1 - - [24/Jul/2019:07:31:35 +0000] "GET /connectors HTTP/1.1" 200 22 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:31:35,522 INFO || 127.0.0.1 - - [24/Jul/2019:07:31:35 +0000] "GET /connectors/cdc-task-myschema-mytable/ HTTP/1.1" 200 1538 2 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:31:35,576 INFO || 127.0.0.1 - - [24/Jul/2019:07:31:35 +0000] "GET /connectors/cdc-task-myschema-mytable/tasks/0/status HTTP/1.1" 200 55 0 [org.apache.kafka.connect.runtime.rest.RestServer]
- 2019-07-24 07:31:58,953 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:58,953 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:31:59,032 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 79 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:32:29,032 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:32:29,032 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask]
- 2019-07-24 07:32:29,095 INFO || WorkerSourceTask{id=cdc-task-myschema-mytable-0} Finished commitOffsets successfully in 63 ms [org.apache.kafka.connect.runtime.WorkerSourceTask]
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement