[2022-09-15 21:00:00,607] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:01,718] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:03,938] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:04,363] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:06,158] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:08,378] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:10,598] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:11,708] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:13,928] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:14,364] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:16,148] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:18,368] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:20,588] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:21,698] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:23,918] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:24,364] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:26,138] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:28,358] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:30,578] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:31,688] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:33,908] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:34,364] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:36,128] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:38,348] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:40,568] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:41,678] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:43,898] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:44,365] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:46,118] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:48,338] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:50,558] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:51,680] TRACE Received LCR oracle.streams.DefaultDDLLCR@4c7e54e7 (io.debezium.connector.oracle.xstream.LcrEventHandler:86)
[2022-09-15 21:00:51,680] TRACE LCR position [0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 3, 0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 2, 2] converted to SCN 000000000038390700000001000000030000000000383907000000010000000202 (io.debezium.connector.oracle.xstream.LcrPosition:43)
[2022-09-15 21:00:51,680] TRACE LCR position [0, 0, 0, 0, 0, 56, 12, -32, 0, 0, 0, 1, 0, 0, 0, 3, 0, 0, 0, 0, 0, 56, 12, -32, 0, 0, 0, 1, 0, 0, 0, 2, 2] converted to SCN 0000000000380ce000000001000000030000000000380ce0000000010000000202 (io.debezium.connector.oracle.xstream.LcrPosition:43)
[2022-09-15 21:00:51,681] DEBUG Processing DDL event create table test_json_clob(id char(3) primary key, content CLOB CONSTRAINT test_json_clob_ensure_json CHECK (content IS JSON)) (io.debezium.connector.oracle.xstream.LcrEventHandler:228)
[2022-09-15 21:00:52,445] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31)
io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table test_json_clob(id char(3) primary key, content CLOB CONSTRAINT test_json_clob_ensure_json CHECK (content IS JSON));'
mismatched input 'JSON' expecting {'A', 'EMPTY', 'INFINITE', 'NAN', 'NOT', 'NULL', 'OF', 'PRESENT'}
	at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
	at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
	at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unary_logical_expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.logical_expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.condition(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.check_constraint(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.inline_constraint(PlSqlParser.java:41494)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.column_definition(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_property(PlSqlParser.java:51556)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:51303)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49617)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2456)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2025)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:73)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32)
	at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:68)
	at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:88)
	at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:308)
	at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchSchemaChangeEvent(LcrEventHandler.java:233)
	at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:118)
	at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
	at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
	at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108)
	at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: org.antlr.v4.runtime.InputMismatchException
	at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270)
	... 32 more
[2022-09-15 21:00:52,448] TRACE Received LCR DefaultRowLCR:
Header:
source database name: PDB1
command type: COMMIT
object owner: 
object name: 
tag: []
position: [0 0 0 0 0 38 39 7 0 0 0 1 0 0 0 3 0 0 0 0 0 38 39 7 0 0 0 1 0 0 0 3 2]
transaction id: 10.13.771
source time: 2022-09-15 21:00:47
scn: null
commit scn: null
lcr flags:
Statement LCR: false
IDKeyColumnsOnly LCR: false
Sequence LCR: false
Attribute[0]
Old column values (0):
New column values (0):
 (io.debezium.connector.oracle.xstream.LcrEventHandler:86)
[2022-09-15 21:00:52,449] TRACE LCR position [0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 3, 0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 3, 2] converted to SCN 000000000038390700000001000000030000000000383907000000010000000302 (io.debezium.connector.oracle.xstream.LcrPosition:43)
[2022-09-15 21:00:52,449] TRACE LCR position [0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 3, 0, 0, 0, 0, 0, 56, 57, 7, 0, 0, 0, 1, 0, 0, 0, 2, 2] converted to SCN 000000000038390700000001000000030000000000383907000000010000000202 (io.debezium.connector.oracle.xstream.LcrPosition:43)
[2022-09-15 21:00:52,449] DEBUG Processing DML event DefaultRowLCR:
Header:
source database name: PDB1
command type: COMMIT
object owner: 
object name: 
tag: []
position: [0 0 0 0 0 38 39 7 0 0 0 1 0 0 0 3 0 0 0 0 0 38 39 7 0 0 0 1 0 0 0 3 2]
transaction id: 10.13.771
source time: 2022-09-15 21:00:47
scn: null
commit scn: null
lcr flags:
Statement LCR: false
IDKeyColumnsOnly LCR: false
Sequence LCR: false
Attribute[0]
Old column values (0):
New column values (0):
 (io.debezium.connector.oracle.xstream.LcrEventHandler:152)
[2022-09-15 21:00:52,449] TRACE Receiving LCR (io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource:107)
[2022-09-15 21:00:52,672] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:52,672] ERROR WorkerSourceTask{id=oracle-test-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:184)
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42)
	at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:128)
	at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
	at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
	at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108)
	at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:172)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement 'create table test_json_clob(id char(3) primary key, content CLOB CONSTRAINT test_json_clob_ensure_json CHECK (content IS JSON));'
mismatched input 'JSON' expecting {'A', 'EMPTY', 'INFINITE', 'NAN', 'NOT', 'NULL', 'OF', 'PRESENT'}
	at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43)
	at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41)
	at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportInputMismatch(DefaultErrorStrategy.java:327)
	at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:139)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unary_logical_expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.logical_expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.expression(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.condition(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.check_constraint(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.inline_constraint(PlSqlParser.java:41494)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.column_definition(PlSqlParser.java)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_property(PlSqlParser.java:51556)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.relational_table(PlSqlParser.java:51303)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.create_table(PlSqlParser.java:49617)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.unit_statement(PlSqlParser.java:2456)
	at io.debezium.ddl.parser.oracle.generated.PlSqlParser.sql_script(PlSqlParser.java:2025)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:73)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parseTree(OracleDdlParser.java:32)
	at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82)
	at io.debezium.connector.oracle.antlr.OracleDdlParser.parse(OracleDdlParser.java:68)
	at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:88)
	at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:308)
	at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchSchemaChangeEvent(LcrEventHandler.java:233)
	at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:118)
	... 12 more
Caused by: org.antlr.v4.runtime.InputMismatchException
	at org.antlr.v4.runtime.DefaultErrorStrategy.sync(DefaultErrorStrategy.java:270)
	... 32 more
[2022-09-15 21:00:52,673] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask:238)
[2022-09-15 21:00:54,365] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:00:54,366] WARN Couldn't commit processed log positions with the source database due to a concurrent connector shutdown or restart (io.debezium.connector.common.BaseSourceTask:289)
[2022-09-15 21:00:54,679] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:980)
[2022-09-15 21:00:54,679] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:173)
[2022-09-15 21:00:54,679] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:70)
[2022-09-15 21:00:54,681] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:980)
[2022-09-15 21:00:54,681] INFO [Producer clientId=CDC-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-15 21:00:54,682] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:00:54,682] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:00:54,683] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:00:54,683] INFO App info kafka.producer for CDC-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:00:54,683] INFO [Producer clientId=connector-producer-oracle-test-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-15 21:00:54,688] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:00:54,688] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:00:54,688] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:00:54,688] INFO App info kafka.producer for connector-producer-oracle-test-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:04,366] INFO WorkerSourceTask{id=oracle-test-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:487)
[2022-09-15 21:01:06,840] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67)
[2022-09-15 21:01:06,840] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:327)
[2022-09-15 21:01:06,842] INFO Stopped http_8083@70e889e9{HTTP/1.1, (http/1.1)}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:381)
[2022-09-15 21:01:06,842] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:149)
[2022-09-15 21:01:06,843] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:344)
[2022-09-15 21:01:06,843] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopping (org.apache.kafka.connect.runtime.distributed.DistributedHerder:718)
[2022-09-15 21:01:06,843] INFO [Worker clientId=connect-1, groupId=connect-cluster] Stopping connectors and tasks that are still assigned to this worker. (org.apache.kafka.connect.runtime.distributed.DistributedHerder:683)
[2022-09-15 21:01:06,844] INFO Stopping connector oracle-test (org.apache.kafka.connect.runtime.Worker:387)
[2022-09-15 21:01:06,844] INFO Scheduled shutdown for WorkerConnector{id=oracle-test} (org.apache.kafka.connect.runtime.WorkerConnector:248)
[2022-09-15 21:01:06,844] INFO Stopping task oracle-test-0 (org.apache.kafka.connect.runtime.Worker:836)
[2022-09-15 21:01:06,844] INFO Completed shutdown for WorkerConnector{id=oracle-test} (org.apache.kafka.connect.runtime.WorkerConnector:268)
[2022-09-15 21:01:06,854] INFO [Worker clientId=connect-1, groupId=connect-cluster] Member connect-1-dc133e58-36cd-40a8-ab4c-29f7e3df10a7 sending LeaveGroup request to coordinator dsq:9092 (id: 2147483647 rack: null) due to the consumer is being closed (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1042)
[2022-09-15 21:01:06,855] WARN [Worker clientId=connect-1, groupId=connect-cluster] Close timed out with 1 pending requests to coordinator, terminating client connections (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:1023)
[2022-09-15 21:01:06,855] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,855] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,855] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,856] INFO App info kafka.connect for connect-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,856] INFO Stopping KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:208)
[2022-09-15 21:01:06,856] INFO [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-15 21:01:06,858] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,858] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,858] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,858] INFO App info kafka.producer for producer-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,858] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,859] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,859] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,859] INFO App info kafka.consumer for consumer-connect-cluster-2 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,860] INFO Stopped KafkaBasedLog for topic connect-status (org.apache.kafka.connect.util.KafkaBasedLog:237)
[2022-09-15 21:01:06,860] INFO Closing KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:295)
[2022-09-15 21:01:06,860] INFO Stopping KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:208)
[2022-09-15 21:01:06,860] INFO [Producer clientId=producer-3] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-15 21:01:06,861] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,861] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,861] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,861] INFO App info kafka.producer for producer-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,862] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,862] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,862] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,863] INFO App info kafka.consumer for consumer-connect-cluster-3 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,863] INFO Stopped KafkaBasedLog for topic connect-configs (org.apache.kafka.connect.util.KafkaBasedLog:237)
[2022-09-15 21:01:06,863] INFO Closed KafkaConfigBackingStore (org.apache.kafka.connect.storage.KafkaConfigBackingStore:303)
[2022-09-15 21:01:06,863] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:209)
[2022-09-15 21:01:06,863] INFO Stopping KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:151)
[2022-09-15 21:01:06,863] INFO Stopping KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:208)
[2022-09-15 21:01:06,864] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-15 21:01:06,865] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,865] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,865] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,865] INFO App info kafka.producer for producer-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,865] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,865] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,865] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,866] INFO App info kafka.consumer for consumer-connect-cluster-1 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,866] INFO Stopped KafkaBasedLog for topic connect-offsets (org.apache.kafka.connect.util.KafkaBasedLog:237)
[2022-09-15 21:01:06,866] INFO Stopped KafkaOffsetBackingStore (org.apache.kafka.connect.storage.KafkaOffsetBackingStore:159)
[2022-09-15 21:01:06,867] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,867] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,867] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,867] INFO App info kafka.connect for 127.0.0.1:8083 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,867] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:230)
[2022-09-15 21:01:06,868] INFO App info kafka.admin.client for adminclient-8 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-15 21:01:06,869] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-15 21:01:06,869] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-15 21:01:06,869] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-15 21:01:06,869] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:321)
[2022-09-15 21:01:06,870] INFO [Worker clientId=connect-1, groupId=connect-cluster] Herder stopped (org.apache.kafka.connect.runtime.distributed.DistributedHerder:738)
[2022-09-15 21:01:06,870] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:72)