2023-08-21 20:42:54,421 INFO Oracle|vk_nau25|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:43:28,809 INFO || [AdminClient clientId=ufo--shared-admin] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-21 20:44:57,881 INFO Oracle|vk_nau25|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:46:26,967 INFO || [AdminClient clientId=connector-adminclient-vk_nau25_src-0] Node 2 disconnected. [org.apache.kafka.clients.NetworkClient] 2023-08-21 20:47:01,641 INFO Oracle|vk_nau25|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:47:53,951 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:53 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:53,953 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:53 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:53,955 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:53 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:53,956 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:53 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,373 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,375 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,377 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,378 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,379 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,379 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,381 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,382 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,384 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,384 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,385 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,387 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,387 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,387 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,389 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,391 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,391 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,392 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:47:56,393 INFO || 10.0.18.18 - - [21/Aug/2023:17:47:56 +0000] "GET /connectors/vk_nau25_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,629 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,633 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2023-08-21 20:48:11,697 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2023-08-21 20:48:11,699 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-21 20:48:11,699 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2023-08-21 20:48:11,702 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau26_src config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,704 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,704 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,705 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "POST /connectors HTTP/1.1" 201 1491 "-" "ReactorNetty/1.1.6" 75 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,705 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769778, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,707 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769778, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,707 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769778 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2195, connectorIds=[vk_nau26_src, vk_nau25_sink, vk_nau25_src, vk_nau24_sink], taskIds=[vk_nau25_sink-0, vk_nau25_src-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,707 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2195 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,707 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connector vk_nau26_src [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,707 INFO || Creating connector vk_nau26_src of type io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,708 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-21 20:48:11,708 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,708 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-21 20:48:11,708 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,708 INFO || Instantiated connector vk_nau26_src with version 2.4.0.Alpha2 of type class io.debezium.connector.oracle.OracleConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,709 INFO || Finished creating connector vk_nau26_src [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,709 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,709 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1491 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,711 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-21 20:48:11,711 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,711 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-21 20:48:11,712 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,713 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 404 73 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,717 INFO || [Worker clientId=connect-1, groupId=ufo] Tasks [vk_nau26_src-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,718 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,718 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,719 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769779, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,720 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769779, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:11,720 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769779 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2197, connectorIds=[vk_nau26_src, vk_nau25_sink, vk_nau25_src, vk_nau24_sink], taskIds=[vk_nau26_src-0, vk_nau25_sink-0, vk_nau25_src-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,720 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2197 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,720 INFO || [Worker clientId=connect-1, groupId=ufo] Starting task vk_nau26_src-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,720 INFO || Creating task vk_nau26_src-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,721 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig] 2023-08-21 20:48:11,721 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,721 INFO || TaskConfig values: task.class = class io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2023-08-21 20:48:11,721 INFO || Instantiated task vk_nau26_src-0 with version 2.4.0.Alpha2 of type io.debezium.connector.oracle.OracleConnectorTask [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,721 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-21 20:48:11,722 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-21 20:48:11,722 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-21 20:48:11,722 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-21 20:48:11,722 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-21 20:48:11,723 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-21 20:48:11,723 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-21 20:48:11,723 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-21 20:48:11,723 INFO || Set up the key converter class io.confluent.connect.avro.AvroConverter for task vk_nau26_src-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,723 INFO || Set up the value converter class io.confluent.connect.avro.AvroConverter for task vk_nau26_src-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,723 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task vk_nau26_src-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,724 INFO || SourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig] 2023-08-21 20:48:11,724 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,724 INFO || EnrichedSourceConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SourceConnectorConfig$EnrichedSourceConnectorConfig] 2023-08-21 20:48:11,724 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.oracle.OracleConnector errors.log.enable = true errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none exactly.once.support = requested header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_src offsets.storage.topic = null predicates = [] tasks.max = 1 topic.creation.default.exclude = [] topic.creation.default.include = [.*] topic.creation.default.partitions = 1 topic.creation.default.replication.factor = 1 topic.creation.groups = [] transaction.boundary = poll transaction.boundary.interval.ms = null transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:48:11,724 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:11,724 INFO || ProducerConfig values: acks = -1 auto.include.jmx.reporter = true batch.size = 16384 bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] buffer.memory = 33554432 client.dns.lookup = use_all_dns_ips client.id = connector-producer-vk_nau26_src-0 compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 2147483647 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 9223372036854775807 max.in.flight.requests.per.connection = 1 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-21 20:48:11,727 INFO || These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-21 20:48:11,727 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,727 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,727 INFO || Kafka startTimeMs: 1692640091727 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,727 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] client.dns.lookup = use_all_dns_ips client.id = connector-adminclient-vk_nau26_src-0 connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 2147483647 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-21 20:48:11,729 INFO || These configurations '[group.id, max.partition.fetch.bytes, rest.advertised.port, task.shutdown.graceful.timeout.ms, plugin.path, metrics.context.connect.kafka.cluster.id, status.storage.replication.factor, offset.storage.topic, value.converter, key.converter, message.max.bytes, config.storage.topic, metrics.context.connect.group.id, rest.advertised.host.name, status.storage.topic, rest.host.name, offset.flush.timeout.ms, config.storage.replication.factor, offset.flush.interval.ms, rest.port, key.converter.schemas.enable, max.request.size, replica.fetch.max.bytes, value.converter.schemas.enable, offset.storage.replication.factor]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-21 20:48:11,729 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,729 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,729 INFO || Kafka startTimeMs: 1692640091729 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,729 INFO || [Producer clientId=connector-producer-vk_nau26_src-0] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-21 20:48:11,730 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:11,730 INFO || Starting OracleConnectorTask with configuration: [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || connector.class = io.debezium.connector.oracle.OracleConnector [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.default.partitions = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || tasks.max = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || schema.history.internal.store.only.captured.tables.ddl = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || schema.history.internal.store.only.captured.databases.ddl = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || include.schema.changes = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.prefix = vk_nau26 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || decimal.handling.mode = precise [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || schema.history.internal.kafka.topic = vk_nau26_src.schema-changes [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.default.include = vk_nau26\.* [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.default.replication.factor = 1 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || lob.enabled = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || value.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || errors.log.enable = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || key.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || snapshot.lock.timeout.ms = 5000 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.user = debezium [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.dbname = NAUMENT1 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || datatype.propagate.source.type = .* [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.default.compression.type = lz4 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.connection.adapter = logminer [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || schema.history.internal.kafka.bootstrap.servers = broker1:29092,broker3:29092,broker3:29092 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.default.retention.ms = 432000000 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.port = 1521 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || topic.creation.enable = true [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || value.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || log.mining.session.max.ms = 120000 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || task.class = io.debezium.connector.oracle.OracleConnectorTask [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.hostname = naumen-db-test.rgs.ru [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,730 INFO || database.password = ******** [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,731 INFO || name = vk_nau26_src [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,731 INFO || table.include.list = DEBEZIUM.GBC_TBL_SERVICECALL_NC26 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,731 INFO || key.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,731 INFO || snapshot.mode = always [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,731 INFO || Loading the custom source info struct maker plugin: io.debezium.connector.oracle.OracleSourceInfoStructMaker [io.debezium.config.CommonConnectorConfig] 2023-08-21 20:48:11,731 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,731 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,732 INFO || Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy [io.debezium.config.CommonConnectorConfig] 2023-08-21 20:48:11,733 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 112 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,736 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:11 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 404 70 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:11,780 INFO || Database Version: Oracle Database 12c Enterprise Edition Release 12.2.0.1.0 - 64bit Production [io.debezium.connector.oracle.OracleConnection] 2023-08-21 20:48:11,788 INFO || KafkaSchemaHistory Consumer config: {key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, enable.auto.commit=false, group.id=vk_nau26-schemahistory, bootstrap.servers=broker1:29092,broker3:29092,broker3:29092, fetch.min.bytes=1, session.timeout.ms=10000, auto.offset.reset=earliest, client.id=vk_nau26-schemahistory} [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-21 20:48:11,788 INFO || KafkaSchemaHistory Producer config: {retries=1, value.serializer=org.apache.kafka.common.serialization.StringSerializer, acks=1, batch.size=32768, max.block.ms=10000, bootstrap.servers=broker1:29092,broker3:29092,broker3:29092, buffer.memory=1048576, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=vk_nau26-schemahistory, linger.ms=0} [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-21 20:48:11,788 INFO || Requested thread factory for connector OracleConnector, id = vk_nau26 named = db-history-config-check [io.debezium.util.Threads] 2023-08-21 20:48:11,789 INFO || Idempotence will be disabled because acks is set to 1, not set to 'all'. [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-21 20:48:11,789 INFO || ProducerConfig values: acks = 1 auto.include.jmx.reporter = true batch.size = 32768 bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] buffer.memory = 1048576 client.dns.lookup = use_all_dns_ips client.id = vk_nau26-schemahistory compression.type = none connections.max.idle.ms = 540000 delivery.timeout.ms = 120000 enable.idempotence = false interceptor.classes = [] key.serializer = class org.apache.kafka.common.serialization.StringSerializer linger.ms = 0 max.block.ms = 10000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metadata.max.idle.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.adaptive.partitioning.enable = true partitioner.availability.timeout.ms = 0 partitioner.class = null partitioner.ignore.keys = false receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.StringSerializer [org.apache.kafka.clients.producer.ProducerConfig] 2023-08-21 20:48:11,795 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,796 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,796 INFO || Kafka startTimeMs: 1692640091795 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,798 INFO || [Producer clientId=vk_nau26-schemahistory] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-21 20:48:11,799 INFO || No previous offsets found [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:11,799 INFO || Connector started for the first time, database schema history recovery will not be executed [io.debezium.connector.oracle.OracleConnectorTask] 2023-08-21 20:48:11,799 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = vk_nau26-schemahistory client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = vk_nau26-schemahistory group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 10000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-21 20:48:11,801 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,801 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,801 INFO || Kafka startTimeMs: 1692640091801 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,802 INFO || [Consumer clientId=vk_nau26-schemahistory, groupId=vk_nau26-schemahistory] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-21 20:48:11,804 INFO || [Consumer clientId=vk_nau26-schemahistory, groupId=vk_nau26-schemahistory] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:48:11,804 INFO || [Consumer clientId=vk_nau26-schemahistory, groupId=vk_nau26-schemahistory] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:48:11,804 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,804 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,804 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,805 INFO || App info kafka.consumer for vk_nau26-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,805 INFO || AdminClientConfig values: auto.include.jmx.reporter = true bootstrap.servers = [broker1:29092, broker3:29092, broker3:29092] client.dns.lookup = use_all_dns_ips client.id = vk_nau26-schemahistory connections.max.idle.ms = 300000 default.api.timeout.ms = 60000 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 1 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-21 20:48:11,806 INFO || These configurations '[value.serializer, acks, batch.size, max.block.ms, buffer.memory, key.serializer, linger.ms]' were supplied but are not used yet. [org.apache.kafka.clients.admin.AdminClientConfig] 2023-08-21 20:48:11,806 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,806 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,806 INFO || Kafka startTimeMs: 1692640091806 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,838 INFO || Database schema history topic '(name=vk_nau26_src.schema-changes, numPartitions=1, replicationFactor=default, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created [io.debezium.storage.kafka.history.KafkaSchemaHistory] 2023-08-21 20:48:11,838 INFO || App info kafka.admin.client for vk_nau26-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:11,839 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,839 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,839 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:11,840 INFO || Requested thread factory for connector OracleConnector, id = vk_nau26 named = SignalProcessor [io.debezium.util.Threads] 2023-08-21 20:48:11,840 INFO || Requested thread factory for connector OracleConnector, id = vk_nau26 named = change-event-source-coordinator [io.debezium.util.Threads] 2023-08-21 20:48:11,840 INFO || Requested thread factory for connector OracleConnector, id = vk_nau26 named = blocking-snapshot [io.debezium.util.Threads] 2023-08-21 20:48:11,840 INFO || Creating thread debezium-oracleconnector-vk_nau26-change-event-source-coordinator [io.debezium.util.Threads] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot Metrics registered [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot Context created [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot Snapshot mode is set to ALWAYS, not checking exiting offset. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot According to the connector configuration both schema and data will be snapshot. [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot Snapshot step 1 - Preparing [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot Snapshot step 2 - Determining captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:11,841 INFO || SignalProcessor started. Scheduling it every 5000ms [io.debezium.pipeline.signal.SignalProcessor] 2023-08-21 20:48:11,841 INFO || Creating thread debezium-oracleconnector-vk_nau26-SignalProcessor [io.debezium.util.Threads] 2023-08-21 20:48:11,841 INFO Oracle|vk_nau26|snapshot WorkerSourceTask{id=vk_nau26_src-0} Source task finished initialization and start [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:12,927 INFO Oracle|vk_nau26|snapshot Adding table NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 to the list of capture schema tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:12,932 INFO Oracle|vk_nau26|snapshot Created connection pool with 1 threads [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:12,932 INFO Oracle|vk_nau26|snapshot Snapshot step 3 - Locking captured tables [NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26] [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:12,935 INFO Oracle|vk_nau26|snapshot Snapshot step 4 - Determining snapshot offset [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:13,052 INFO Oracle|vk_nau26|snapshot No in-progress transactions will be captured. [io.debezium.connector.oracle.logminer.LogMinerAdapter] 2023-08-21 20:48:13,053 INFO Oracle|vk_nau26|snapshot Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-21 20:48:13,054 INFO Oracle|vk_nau26|snapshot Snapshot step 5 - Reading structure of captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:13,054 INFO Oracle|vk_nau26|snapshot Only captured tables schema should be captured, capturing: [NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26] [io.debezium.connector.oracle.OracleSnapshotChangeEventSource] 2023-08-21 20:48:13,370 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors HTTP/1.1" 200 63 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,374 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,374 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,374 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,374 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,376 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,378 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,379 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,380 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,381 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,382 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,383 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,384 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,385 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,387 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,388 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,390 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 5 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,391 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,391 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,392 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,393 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,396 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 30 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,396 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,397 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,399 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:13 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:13,668 INFO Oracle|vk_nau26|snapshot Snapshot step 6 - Persisting schema history [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:13,668 INFO Oracle|vk_nau26|snapshot Capturing structure of table NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,044 INFO Oracle|vk_nau26|snapshot Already applied 1 database changes [io.debezium.relational.history.SchemaHistoryMetrics] 2023-08-21 20:48:16,046 INFO Oracle|vk_nau26|snapshot Snapshot step 7 - Snapshotting data [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,046 INFO Oracle|vk_nau26|snapshot Creating snapshot worker pool with 1 worker thread(s) [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,046 INFO Oracle|vk_nau26|snapshot For table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' using select statement: 'SELECT "ID", "CREATION_DATE", "TITLE", "CLIENT_EMAIL" FROM "DEBEZIUM"."GBC_TBL_SERVICECALL_NC26" AS OF SCN 289884598732' [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,046 INFO Oracle|vk_nau26|snapshot Exporting data from table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' (1 of 1 tables) [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,222 INFO Oracle|vk_nau26|snapshot Finished exporting 2000 records for table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' (1 of 1 tables); total duration '00:00:00.176' [io.debezium.relational.RelationalSnapshotChangeEventSource] 2023-08-21 20:48:16,223 INFO Oracle|vk_nau26|snapshot Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2023-08-21 20:48:16,223 INFO Oracle|vk_nau26|snapshot Snapshot completed [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource] 2023-08-21 20:48:16,223 INFO Oracle|vk_nau26|snapshot Snapshot ended with SnapshotResult [status=COMPLETED, offset=OracleOffsetContext [scn=289884598732, commit_scn=[]]] [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:16,223 INFO Oracle|vk_nau26|streaming Connected metrics set to 'true' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:16,223 INFO Oracle|vk_nau26|streaming Starting streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:16,364 INFO Oracle|vk_nau26|snapshot The task will send records to topic 'vk_nau26' for the first time. Checking whether topic exists [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,366 INFO Oracle|vk_nau26|snapshot Creating topic 'vk_nau26' [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,395 INFO Oracle|vk_nau26|snapshot Created topic (name=vk_nau26, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000}) on brokers at broker1:29092,broker2:29092,broker3:29092 [org.apache.kafka.connect.util.TopicAdmin] 2023-08-21 20:48:16,395 INFO Oracle|vk_nau26|snapshot Created topic '(name=vk_nau26, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000})' using creation group TopicCreationGroup{name='default', inclusionPattern=.*, exclusionPattern=, numPartitions=1, replicationFactor=1, otherConfigs={compression.type=lz4, retention.ms=432000000}} [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,409 INFO Oracle|vk_nau26|snapshot The task will send records to topic 'vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' for the first time. Checking whether topic exists [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,410 INFO Oracle|vk_nau26|snapshot Creating topic 'vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,438 INFO Oracle|vk_nau26|snapshot Created topic (name=vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000}) on brokers at broker1:29092,broker2:29092,broker3:29092 [org.apache.kafka.connect.util.TopicAdmin] 2023-08-21 20:48:16,438 INFO Oracle|vk_nau26|snapshot Created topic '(name=vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=lz4, retention.ms=432000000})' using creation group TopicCreationGroup{name='default', inclusionPattern=.*, exclusionPattern=, numPartitions=1, replicationFactor=1, otherConfigs={compression.type=lz4, retention.ms=432000000}} [org.apache.kafka.connect.runtime.AbstractWorkerSourceTask] 2023-08-21 20:48:16,441 WARN || [Producer clientId=connector-producer-vk_nau26_src-0] Got error produce response with correlation id 7 on topic-partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0, retrying (2147483646 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION [org.apache.kafka.clients.producer.internals.Sender] 2023-08-21 20:48:16,441 WARN || [Producer clientId=connector-producer-vk_nau26_src-0] Received unknown topic or partition error in produce request on partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0. The topic-partition may not exist or the user may not have Describe access to it [org.apache.kafka.clients.producer.internals.Sender] 2023-08-21 20:48:16,471 WARN Oracle|vk_nau26|streaming Database table 'NAUMENT1.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' not configured with supplemental logging "(ALL) COLUMNS"; only explicitly changed columns will be captured. Use: ALTER TABLE DEBEZIUM.GBC_TBL_SERVICECALL_NC26 ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Redo Log Group Sizes: [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #1: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #2: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #3: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #4: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #5: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #6: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,474 INFO Oracle|vk_nau26|streaming Group #7: 536870912 bytes [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:16,540 WARN || [Producer clientId=connector-producer-vk_nau26_src-0] Error while fetching metadata with correlation id 8 : {vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26=UNKNOWN_TOPIC_OR_PARTITION} [org.apache.kafka.clients.NetworkClient] 2023-08-21 20:48:16,540 INFO || [Producer clientId=connector-producer-vk_nau26_src-0] Resetting the last seen epoch of partition vk_nau26-0 to 0 since the associated topicId changed from null to tV9w9itlS9-MGWPxyIzm7Q [org.apache.kafka.clients.Metadata] 2023-08-21 20:48:16,641 INFO || [Producer clientId=connector-producer-vk_nau26_src-0] Resetting the last seen epoch of partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0 to 0 since the associated topicId changed from null to PL2zgrjPTM-HXqkFCgHYYA [org.apache.kafka.clients.Metadata] 2023-08-21 20:48:16,641 WARN || [Producer clientId=connector-producer-vk_nau26_src-0] Got error produce response with correlation id 10 on topic-partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0, retrying (2147483645 attempts left). Error: UNKNOWN_TOPIC_OR_PARTITION [org.apache.kafka.clients.producer.internals.Sender] 2023-08-21 20:48:16,641 WARN || [Producer clientId=connector-producer-vk_nau26_src-0] Received unknown topic or partition error in produce request on partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0. The topic-partition may not exist or the user may not have Describe access to it [org.apache.kafka.clients.producer.internals.Sender] 2023-08-21 20:48:22,278 INFO || Successfully processed removal of connector 'vk_nau25_src' [org.apache.kafka.connect.storage.KafkaConfigBackingStore] 2023-08-21 20:48:22,278 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau25_src config removed [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:22,278 INFO || [Worker clientId=connect-1, groupId=ufo] Handling connector-only config update by stopping connector vk_nau25_src [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:22,278 INFO || Stopping connector vk_nau25_src [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:22,278 INFO || Scheduled shutdown for WorkerConnector{id=vk_nau25_src} [org.apache.kafka.connect.runtime.WorkerConnector] 2023-08-21 20:48:22,278 INFO || Completed shutdown for WorkerConnector{id=vk_nau25_src} [org.apache.kafka.connect.runtime.WorkerConnector] 2023-08-21 20:48:22,280 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:22 +0000] "DELETE /connectors/vk_nau25_src HTTP/1.1" 204 0 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:22,280 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:22,280 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:22,281 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769780, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:22,282 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769780, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:22,283 INFO || Stopping connector vk_nau25_src [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:22,283 WARN || Ignoring stop request for unowned connector vk_nau25_src [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:22,283 INFO || Stopping task vk_nau25_src-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:22,283 WARN || Ignoring await stop request for non-present connector vk_nau25_src [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:22,287 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:22 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:22,413 INFO Oracle|vk_nau25|snapshot Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2023-08-21 20:48:28,969 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:28 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,283 ERROR || Graceful stop of task vk_nau25_src-0 failed. [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:48:32,283 INFO || [Producer clientId=connector-producer-vk_nau25_src-0] Closing the Kafka producer with timeoutMillis = 0 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-21 20:48:32,283 INFO || [Producer clientId=connector-producer-vk_nau25_src-0] Proceeding to force close the producer since pending requests could not be completed within timeout 0 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-21 20:48:32,284 INFO || [Worker clientId=connect-1, groupId=ufo] Finished stopping tasks in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,286 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:32,286 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:32,286 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:32,286 INFO || App info kafka.producer for connector-producer-vk_nau25_src-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:32,286 INFO || [Worker clientId=connect-1, groupId=ufo] Finished flushing status backing store in preparation for rebalance [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,287 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769780 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2199, connectorIds=[vk_nau26_src, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau26_src-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[vk_nau25_src], revokedTaskIds=[vk_nau25_src-0], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,287 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2199 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,287 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,287 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:32,287 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:32,288 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769781, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:32,289 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769781, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:48:32,290 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769781 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2199, connectorIds=[vk_nau26_src, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau26_src-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,290 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2199 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,290 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:48:32,292 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:28 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3319 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,292 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:25 +0000] "DELETE /connectors/vk_nau25_src HTTP/1.1" 404 63 "-" "ReactorNetty/1.1.6" 6322 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,292 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:22 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9996 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,293 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:28 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 3319 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,293 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:22 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 9997 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,295 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:22 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 9999 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,295 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,296 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:28 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3323 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,297 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 0 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,300 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,301 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,302 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,303 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,304 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,304 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,306 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,307 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,308 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,310 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,310 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,311 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:32,312 INFO || 10.0.18.18 - - [21/Aug/2023:17:48:32 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:48:55,128 INFO Oracle|vk_nau25|streaming startScn=289884598819, endScn=289884609744 [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:55,129 INFO Oracle|vk_nau25|streaming Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=289884609744, oldestScn=-1, committedScn=289884598819, offsetScn=289884598733, logMinerQueryCount=580, totalProcessedRows=304887, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT4M7.199455S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT9.6716S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT9.6716S, totalBatchProcessingDuration=PT9M25.401724S, lastBatchProcessingDuration=PT32.899466S, maxBatchProcessingThroughput=0, currentLogFileName=[/u04/oradata/naument1/redo_05b.log, /u02/oradata/naument1/redo_05a.log], minLogFilesMined=2, maxLogFilesMined=2, redoLogStatus=[/u02/oradata/naument1/redo_07a.log | ACTIVE, /u04/oradata/naument1/redo_07b.log | ACTIVE, /u02/oradata/naument1/redo_06a.log | ACTIVE, /u04/oradata/naument1/redo_06b.log | ACTIVE, /u02/oradata/naument1/redo_04a.log | ACTIVE, /u02/oradata/naument1/redo_01a.log | ACTIVE, /u04/oradata/naument1/redo_01b.log | ACTIVE, /u04/oradata/naument1/redo_04b.log | ACTIVE, /u02/oradata/naument1/redo_03a.log | ACTIVE, /u04/oradata/naument1/redo_03b.log | ACTIVE, /u02/oradata/naument1/redo_02a.log | ACTIVE, /u04/oradata/naument1/redo_02b.log | ACTIVE, /u04/oradata/naument1/redo_05b.log | CURRENT, /u02/oradata/naument1/redo_05a.log | CURRENT], switchCounter=548, batchSize=20000, millisecondToSleepBetweenMiningQuery=3000, keepTransactionsDuration=PT0S, networkConnectionProblemsCounter0, batchSizeDefault=20000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT4M6.990982S, lastStartLogMiningSessionDuration=PT20.665829S, maxStartLogMiningSessionDuration=PT20.665829S, totalProcessTime=PT9M25.401724S, minBatchProcessTime=PT0.08523S, maxBatchProcessTime=PT32.899466S, totalResultSetNextTime=PT15.803198S, lagFromTheSource=DurationPT0.403529S, maxLagFromTheSourceDuration=PT47.234013S, minLagFromTheSourceDuration=PT0.1521S, lastCommitDuration=PT0.000003S, maxCommitDuration=PT0.004854S, activeTransactions=0, rolledBackTransactions=1652, oversizedTransactions=0, committedTransactions=143904, abandonedTransactionIds={}, rolledbackTransactionIds={110006005dda2a00=110006005dda2a00, 03000800e95d2800=03000800e95d2800, 05000100621c2b00=05000100621c2b00, 090012003b982f00=090012003b982f00, 13001c00d9642b00=13001c00d9642b00, 04000100bb7c2a00=04000100bb7c2a00, 0700020009792d00=0700020009792d00, 0c000d003b092b00=0c000d003b092b00, 08000d00360a2e00=08000d00360a2e00, 070018002e792d00=070018002e792d00}, registeredDmlCount=0, committedDmlCount=0, errorCount=0, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=23568792, miningSessionUserGlobalAreaMaxMemory=41484808, miningSessionProcessGlobalAreaMemory=71154504, miningSessionProcessGlobalAreaMaxMemory=106871624} [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:55,129 INFO Oracle|vk_nau25|streaming Offsets: OracleOffsetContext [scn=289884598819, commit_scn=["289884594692:0:01001b0089652500-020002003c792700-04000d00f07e2a00-050003004e1a2b00-06000d007dac2900-0700140079762d00-0800140005062e00-0a0014002ad03000-0d00050035872900-0e0009006fed2800-0f0018002b9a2900-10000e00b8e32900-110018001ad62a00-12001a0046f52900-130017004d692b00-14000e000a5c2b00","289884598819:1:1100090056e12a00"]] [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:48:55,129 INFO Oracle|vk_nau25|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:55,129 INFO Oracle|vk_nau25|streaming Connected metrics set to 'false' [io.debezium.pipeline.ChangeEventSourceCoordinator] 2023-08-21 20:48:55,129 INFO Oracle|vk_nau25|snapshot SignalProcessor stopped [io.debezium.pipeline.signal.SignalProcessor] 2023-08-21 20:48:55,142 INFO Oracle|vk_nau25|snapshot Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2023-08-21 20:48:55,142 INFO Oracle|vk_nau25|snapshot [Producer clientId=vk_nau25-schemahistory] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot App info kafka.producer for vk_nau25-schemahistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot [Producer clientId=connector-producer-vk_nau25_src-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,143 INFO Oracle|vk_nau25|snapshot App info kafka.producer for connector-producer-vk_nau25_src-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:55,144 INFO || App info kafka.admin.client for connector-adminclient-vk_nau25_src-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:48:55,145 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,145 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:48:55,145 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:49:11,730 INFO || WorkerSourceTask{id=vk_nau26_src-0} Committing offsets for 2001 acknowledged messages [org.apache.kafka.connect.runtime.WorkerSourceTask] 2023-08-21 20:50:31,074 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,078 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,078 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,078 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,080 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,081 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,081 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,084 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,084 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,085 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,086 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,088 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,089 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,090 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,091 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,092 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,093 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,093 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:31,095 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:31 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,694 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,697 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,697 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,697 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,699 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,699 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,699 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,703 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,703 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,703 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,705 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,705 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,706 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,708 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,708 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,708 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,710 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,710 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:40,710 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:40 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,574 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,577 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,579 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,580 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,580 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,581 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,582 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,582 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,585 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,585 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,586 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,588 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,589 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,589 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,591 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,592 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,593 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,594 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:50,594 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:50 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:52,387 INFO Oracle|vk_nau26|streaming LogMiner session has exceeded maximum session time of 'Optional[PT2M]', forcing restart. [io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource] 2023-08-21 20:50:57,957 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors HTTP/1.1" 200 48 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,960 INFO || AbstractConfig values: [org.apache.kafka.common.config.AbstractConfig] 2023-08-21 20:50:57,962 INFO || [Worker clientId=connect-1, groupId=ufo] Connector vk_nau26_sink config updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,963 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,963 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,964 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "POST /connectors HTTP/1.1" 201 868 "-" "ReactorNetty/1.1.6" 6 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,964 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769782, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,966 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769782, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,966 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769782 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2200, connectorIds=[vk_nau26_sink, vk_nau26_src, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau26_src-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,966 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2200 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,966 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connector vk_nau26_sink [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,966 INFO || Creating connector vk_nau26_sink of type io.debezium.connector.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,967 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-21 20:50:57,967 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:50:57,967 INFO || Instantiated connector vk_nau26_sink with version 2.4.0.Alpha2 of type class io.debezium.connector.jdbc.JdbcSinkConnector [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,968 INFO || Finished creating connector vk_nau26_sink [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,968 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,968 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-21 20:50:57,968 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:50:57,969 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 868 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,971 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 404 74 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,975 INFO || [Worker clientId=connect-1, groupId=ufo] Tasks [vk_nau26_sink-0] configs updated [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,976 INFO || [Worker clientId=connect-1, groupId=ufo] Rebalance started [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,976 INFO || [Worker clientId=connect-1, groupId=ufo] (Re-)joining group [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,977 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully joined group with generation Generation{generationId=105769783, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,978 INFO || [Worker clientId=connect-1, groupId=ufo] Successfully synced group in generation Generation{generationId=105769783, memberId='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', protocol='sessioned'} [org.apache.kafka.connect.runtime.distributed.WorkerCoordinator] 2023-08-21 20:50:57,978 INFO || [Worker clientId=connect-1, groupId=ufo] Joined group at generation 105769783 with protocol version 2 and got assignment: Assignment{error=0, leader='connect-1-d436cdf8-3a67-459e-8436-8781c486908b', leaderUrl='http://172.18.0.7:8083/', offset=2202, connectorIds=[vk_nau26_sink, vk_nau26_src, vk_nau25_sink, vk_nau24_sink], taskIds=[vk_nau26_sink-0, vk_nau26_src-0, vk_nau25_sink-0, vk_nau24_sink-0], revokedConnectorIds=[], revokedTaskIds=[], delay=0} with rebalance delay: 0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,978 INFO || [Worker clientId=connect-1, groupId=ufo] Starting connectors and tasks using config offset 2202 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,979 INFO || [Worker clientId=connect-1, groupId=ufo] Starting task vk_nau26_sink-0 [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,979 INFO || Creating task vk_nau26_sink-0 [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,979 INFO || ConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig] 2023-08-21 20:50:57,979 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:50:57,979 INFO || TaskConfig values: task.class = class io.debezium.connector.jdbc.JdbcSinkConnectorTask [org.apache.kafka.connect.runtime.TaskConfig] 2023-08-21 20:50:57,979 INFO || Instantiated task vk_nau26_sink-0 with version 2.4.0.Alpha2 of type io.debezium.connector.jdbc.JdbcSinkConnectorTask [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,979 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-21 20:50:57,980 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-21 20:50:57,980 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-21 20:50:57,980 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-21 20:50:57,980 INFO || AvroConverterConfig values: auto.register.schemas = true basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.connect.avro.AvroConverterConfig] 2023-08-21 20:50:57,980 INFO || KafkaAvroSerializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.remove.java.properties = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroSerializerConfig] 2023-08-21 20:50:57,980 INFO || KafkaAvroDeserializerConfig values: auto.register.schemas = true avro.reflection.allow.null = false avro.use.logical.type.converters = false basic.auth.credentials.source = URL basic.auth.user.info = [hidden] bearer.auth.cache.expiry.buffer.seconds = 300 bearer.auth.client.id = null bearer.auth.client.secret = null bearer.auth.credentials.source = STATIC_TOKEN bearer.auth.identity.pool.id = null bearer.auth.issuer.endpoint.url = null bearer.auth.logical.cluster = null bearer.auth.scope = null bearer.auth.scope.claim.name = scope bearer.auth.sub.claim.name = sub bearer.auth.token = [hidden] context.name.strategy = class io.confluent.kafka.serializers.context.NullContextNameStrategy id.compatibility.strict = true key.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy latest.compatibility.strict = true max.schemas.per.subject = 1000 normalize.schemas = false proxy.host = proxy.port = -1 schema.format = null schema.reflection = false schema.registry.basic.auth.user.info = [hidden] schema.registry.ssl.cipher.suites = null schema.registry.ssl.enabled.protocols = [TLSv1.2, TLSv1.3] schema.registry.ssl.endpoint.identification.algorithm = https schema.registry.ssl.engine.factory.class = null schema.registry.ssl.key.password = null schema.registry.ssl.keymanager.algorithm = SunX509 schema.registry.ssl.keystore.certificate.chain = null schema.registry.ssl.keystore.key = null schema.registry.ssl.keystore.location = null schema.registry.ssl.keystore.password = null schema.registry.ssl.keystore.type = JKS schema.registry.ssl.protocol = TLSv1.3 schema.registry.ssl.provider = null schema.registry.ssl.secure.random.implementation = null schema.registry.ssl.trustmanager.algorithm = PKIX schema.registry.ssl.truststore.certificates = null schema.registry.ssl.truststore.location = null schema.registry.ssl.truststore.password = null schema.registry.ssl.truststore.type = JKS schema.registry.url = [http://naument-sr:8081] specific.avro.reader = false use.latest.version = false use.schema.id = -1 value.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy [io.confluent.kafka.serializers.KafkaAvroDeserializerConfig] 2023-08-21 20:50:57,980 INFO || AvroDataConfig values: connect.meta.data = true discard.type.doc.default = false enhanced.avro.schema.support = false generalized.sum.type.support = false ignore.default.for.nullables = false schemas.cache.config = 1000 scrub.invalid.names = false [io.confluent.connect.avro.AvroDataConfig] 2023-08-21 20:50:57,980 INFO || Set up the key converter class io.confluent.connect.avro.AvroConverter for task vk_nau26_sink-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,980 INFO || Set up the value converter class io.confluent.connect.avro.AvroConverter for task vk_nau26_sink-0 using the connector config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,980 INFO || Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task vk_nau26_sink-0 using the worker config [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,981 INFO || Initializing: org.apache.kafka.connect.runtime.TransformationChain{} [org.apache.kafka.connect.runtime.Worker] 2023-08-21 20:50:57,981 INFO || SinkConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.SinkConnectorConfig] 2023-08-21 20:50:57,981 INFO || EnrichedConnectorConfig values: config.action.reload = restart connector.class = io.debezium.connector.jdbc.JdbcSinkConnector errors.deadletterqueue.context.headers.enable = false errors.deadletterqueue.topic.name = errors.deadletterqueue.topic.replication.factor = 3 errors.log.enable = false errors.log.include.messages = false errors.retry.delay.max.ms = 60000 errors.retry.timeout = 0 errors.tolerance = none header.converter = null key.converter = class io.confluent.connect.avro.AvroConverter name = vk_nau26_sink predicates = [] tasks.max = 1 topics = [] topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 transforms = [] value.converter = class io.confluent.connect.avro.AvroConverter [org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig] 2023-08-21 20:50:57,981 INFO || ConsumerConfig values: allow.auto.create.topics = true auto.commit.interval.ms = 5000 auto.include.jmx.reporter = true auto.offset.reset = earliest bootstrap.servers = [broker1:29092, broker2:29092, broker3:29092] check.crcs = true client.dns.lookup = use_all_dns_ips client.id = connector-consumer-vk_nau26_sink-0 client.rack = connections.max.idle.ms = 540000 default.api.timeout.ms = 60000 enable.auto.commit = false exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = connect-vk_nau26_sink group.instance.id = null heartbeat.interval.ms = 3000 interceptor.classes = [] internal.leave.group.on.close = true internal.throw.on.fetch.stable.offset.unsupported = false isolation.level = read_uncommitted key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor, class org.apache.kafka.clients.consumer.CooperativeStickyAssignor] receive.buffer.bytes = 65536 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retry.backoff.ms = 100 sasl.client.callback.handler.class = null sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.login.callback.handler.class = null sasl.login.class = null sasl.login.connect.timeout.ms = null sasl.login.read.timeout.ms = null sasl.login.refresh.buffer.seconds = 300 sasl.login.refresh.min.period.seconds = 60 sasl.login.refresh.window.factor = 0.8 sasl.login.refresh.window.jitter = 0.05 sasl.login.retry.backoff.max.ms = 10000 sasl.login.retry.backoff.ms = 100 sasl.mechanism = GSSAPI sasl.oauthbearer.clock.skew.seconds = 30 sasl.oauthbearer.expected.audience = null sasl.oauthbearer.expected.issuer = null sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000 sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100 sasl.oauthbearer.jwks.endpoint.url = null sasl.oauthbearer.scope.claim.name = scope sasl.oauthbearer.sub.claim.name = sub sasl.oauthbearer.token.endpoint.url = null security.protocol = PLAINTEXT security.providers = null send.buffer.bytes = 131072 session.timeout.ms = 45000 socket.connection.setup.timeout.max.ms = 30000 socket.connection.setup.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-21 20:50:57,984 INFO || These configurations '[metrics.context.connect.kafka.cluster.id, metrics.context.connect.group.id]' were supplied but are not used yet. [org.apache.kafka.clients.consumer.ConsumerConfig] 2023-08-21 20:50:57,984 INFO || Kafka version: 3.5.1 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:50:57,984 INFO || Kafka commitId: 2c6fb6c54472e90a [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:50:57,984 INFO || Kafka startTimeMs: 1692640257984 [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:50:57,985 INFO || [Worker clientId=connect-1, groupId=ufo] Finished starting connectors and tasks [org.apache.kafka.connect.runtime.distributed.DistributedHerder] 2023-08-21 20:50:57,985 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Subscribed to pattern: 'vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26' [org.apache.kafka.clients.consumer.KafkaConsumer] 2023-08-21 20:50:57,986 INFO || Starting JdbcSinkConnectorConfig with configuration: [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || connector.class = io.debezium.connector.jdbc.JdbcSinkConnector [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || table.name.format = vk_nau26_tbl_servicecall [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || primary.key.mode = record_key [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || connection.password = ******** [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || tasks.max = 1 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || connection.username = debeziumt [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || quote.identifiers = false [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || topics.regex = vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || value.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || delete.enabled = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || schema.evolution = basic [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || auto.evolve = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || task.class = io.debezium.connector.jdbc.JdbcSinkConnectorTask [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || name = vk_nau26_sink [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || auto.create = true [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || value.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || connection.url = jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || insert.mode = upsert [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || key.converter = io.confluent.connect.avro.AvroConverter [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || key.converter.schema.registry.url = http://naument-sr:8081 [io.debezium.connector.jdbc.JdbcSinkConnectorTask] 2023-08-21 20:50:57,986 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,987 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,989 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 111 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,990 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:57 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 404 71 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:57,993 INFO || HHH000130: Instantiating explicit connection provider: org.hibernate.c3p0.internal.C3P0ConnectionProvider [org.hibernate.engine.jdbc.connections.internal.ConnectionProviderInitiator] 2023-08-21 20:50:57,993 INFO || HHH010002: C3P0 using driver: null at URL: jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1 [org.hibernate.orm.connections.pooling.c3p0] 2023-08-21 20:50:57,993 INFO || HHH10001001: Connection properties: {password=****, user=debeziumt} [org.hibernate.orm.connections.pooling.c3p0] 2023-08-21 20:50:57,993 INFO || HHH10001003: Autocommit mode: false [org.hibernate.orm.connections.pooling.c3p0] 2023-08-21 20:50:57,993 WARN || HHH10001006: No JDBC Driver class was specified by property hibernate.connection.driver_class [org.hibernate.orm.connections.pooling.c3p0] 2023-08-21 20:50:58,015 INFO || HHH10001007: JDBC isolation level: [org.hibernate.orm.connections.pooling.c3p0] 2023-08-21 20:50:58,016 INFO || Initializing c3p0 pool... com.mchange.v2.c3p0.PoolBackedDataSource@74a4203e [ connectionPoolDataSource -> com.mchange.v2.c3p0.WrapperConnectionPoolDataSource@9c5bb0dd [ acquireIncrement -> 32, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, contextClassLoaderSource -> caller, debugUnreturnedConnectionStackTraces -> false, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, forceSynchronousCheckins -> false, identityToken -> 2rw1gkax1xb7t5zy4t5mp|550fce1f, idleConnectionTestPeriod -> 0, initialPoolSize -> 5, maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 32, maxStatements -> 0, maxStatementsPerConnection -> 0, minPoolSize -> 5, nestedDataSource -> com.mchange.v2.c3p0.DriverManagerDataSource@eeec359d [ description -> null, driverClass -> null, factoryClassLocation -> null, forceUseNamedDriverClass -> false, identityToken -> 2rw1gkax1xb7t5zy4t5mp|796cfffd, jdbcUrl -> jdbc:postgresql://dwh-db-test.rgs.ru:5438/db_ods_test?currentSchema=naument1, properties -> {password=******, user=******} ], preferredTestQuery -> null, privilegeSpawnedThreads -> false, propertyCycle -> 0, statementCacheNumDeferredCloseThreads -> 0, testConnectionOnCheckin -> false, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, usesTraditionalReflectiveProxies -> false; userOverrides: {} ], dataSourceName -> null, extensions -> {}, factoryClassLocation -> null, identityToken -> 2rw1gkax1xb7t5zy4t5mp|3e90916a, numHelperThreads -> 3 ] [com.mchange.v2.c3p0.impl.AbstractPoolBackedDataSource] 2023-08-21 20:50:58,037 INFO || HHH000400: Using dialect: org.hibernate.dialect.PostgreSQLDialect [SQL dialect] 2023-08-21 20:50:58,049 INFO || HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform] [org.hibernate.engine.transaction.jta.platform.internal.JtaPlatformInitiator] 2023-08-21 20:50:58,049 INFO || Using dialect io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect [io.debezium.connector.jdbc.dialect.DatabaseDialectResolver] 2023-08-21 20:50:58,053 INFO || Database TimeZone: Europe/Moscow [io.debezium.connector.jdbc.dialect.GeneralDatabaseDialect] 2023-08-21 20:50:58,053 INFO || Database version 13.2.0 [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-21 20:50:58,053 INFO || WorkerSinkTask{id=vk_nau26_sink-0} Sink task finished initialization and start [org.apache.kafka.connect.runtime.WorkerSinkTask] 2023-08-21 20:50:58,054 INFO || WorkerSinkTask{id=vk_nau26_sink-0} Executing sink task [org.apache.kafka.connect.runtime.WorkerSinkTask] 2023-08-21 20:50:58,057 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Cluster ID: gVJjK6cZTd-nXsXP2EIHEQ [org.apache.kafka.clients.Metadata] 2023-08-21 20:50:58,057 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Discovered group coordinator broker3:29092 (id: 2147483644 rack: null) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,057 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,060 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Request joining group due to: need to re-join with the given member-id: connector-consumer-vk_nau26_sink-0-95244a1a-0188-429f-8458-6c06c63be274 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,060 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Request joining group due to: rebalance failed due to 'The group member needs to have a valid member id before actually entering a consumer group.' (MemberIdRequiredException) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,060 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] (Re-)joining group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,062 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Successfully joined group with generation Generation{generationId=1, memberId='connector-consumer-vk_nau26_sink-0-95244a1a-0188-429f-8458-6c06c63be274', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,062 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Finished assignment for group at generation 1: {connector-consumer-vk_nau26_sink-0-95244a1a-0188-429f-8458-6c06c63be274=Assignment(partitions=[vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0])} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,063 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Successfully synced group in generation Generation{generationId=1, memberId='connector-consumer-vk_nau26_sink-0-95244a1a-0188-429f-8458-6c06c63be274', protocol='range'} [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,063 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Notifying assignor about the new Assignment(partitions=[vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0]) [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,063 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Adding newly assigned partitions: vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,064 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Found no committed offset for partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,065 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Resetting offset for partition vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker1:29092 (id: 1 rack: null)], epoch=0}}. [org.apache.kafka.clients.consumer.internals.SubscriptionState] Hibernate: CREATE TABLE vk_nau26_tbl_servicecall (ID decimal(19,0) NOT NULL, CREATION_DATE timestamp(6) NOT NULL, TITLE varchar(4000) NULL, CLIENT_EMAIL varchar(255) NULL, PRIMARY KEY(ID)) Hibernate: INSERT INTO naument1.vk_nau26_tbl_servicecall (ID,CREATION_DATE,TITLE,CLIENT_EMAIL) VALUES (?,?,?,?) ON CONFLICT (ID) DO UPDATE SET CREATION_DATE=EXCLUDED.CREATION_DATE,TITLE=EXCLUDED.TITLE,CLIENT_EMAIL=EXCLUDED.CLIENT_EMAIL 2023-08-21 20:50:58,123 ERROR || Failed to alter the table 'vk_nau26_tbl_servicecall'. [io.debezium.connector.jdbc.JdbcChangeEventSink] java.sql.SQLException: Cannot ALTER table 'vk_nau26_tbl_servicecall' because field 'CREATION_DATE' is not optional but has no default value at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:190) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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:829) 2023-08-21 20:50:58,124 ERROR || Failed to process record: Failed to process a sink record [io.debezium.connector.jdbc.JdbcSinkConnectorTask] org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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:829) Caused by: java.sql.SQLException: Cannot ALTER table 'vk_nau26_tbl_servicecall' because field 'CREATION_DATE' is not optional but has no default value at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:190) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more 2023-08-21 20:50:58,137 ERROR || WorkerSinkTask{id=vk_nau26_sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: JDBC sink connector failure [org.apache.kafka.connect.runtime.WorkerSinkTask] org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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:829) Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: java.sql.SQLException: Cannot ALTER table 'vk_nau26_tbl_servicecall' because field 'CREATION_DATE' is not optional but has no default value at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:190) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more 2023-08-21 20:50:58,139 ERROR || WorkerSinkTask{id=vk_nau26_sink-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] org.apache.kafka.connect.errors.ConnectException: Exiting WorkerSinkTask due to unrecoverable exception. at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:618) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:336) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:237) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:206) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:204) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:259) at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:181) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) 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:829) Caused by: org.apache.kafka.connect.errors.ConnectException: JDBC sink connector failure at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:83) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:587) ... 11 more Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to process a sink record at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:82) at io.debezium.connector.jdbc.JdbcSinkConnectorTask.put(JdbcSinkConnectorTask.java:93) ... 12 more Caused by: java.sql.SQLException: Cannot ALTER table 'vk_nau26_tbl_servicecall' because field 'CREATION_DATE' is not optional but has no default value at io.debezium.connector.jdbc.JdbcChangeEventSink.alterTableIfNeeded(JdbcChangeEventSink.java:190) at io.debezium.connector.jdbc.JdbcChangeEventSink.checkAndApplyTableChangesIfNeeded(JdbcChangeEventSink.java:127) at io.debezium.connector.jdbc.JdbcChangeEventSink.execute(JdbcChangeEventSink.java:78) ... 13 more 2023-08-21 20:50:58,139 INFO || Closing session. [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-21 20:50:58,140 INFO || Closing the session factory [io.debezium.connector.jdbc.JdbcChangeEventSink] 2023-08-21 20:50:58,142 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Revoke previously assigned partitions vk_nau26.DEBEZIUM.GBC_TBL_SERVICECALL_NC26-0 [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,142 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Member connector-consumer-vk_nau26_sink-0-95244a1a-0188-429f-8458-6c06c63be274 sending LeaveGroup request to coordinator broker3:29092 (id: 2147483644 rack: null) due to the consumer is being closed [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,142 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Resetting generation and member id due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,142 INFO || [Consumer clientId=connector-consumer-vk_nau26_sink-0, groupId=connect-vk_nau26_sink] Request joining group due to: consumer pro-actively leaving the group [org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] 2023-08-21 20:50:58,145 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:50:58,145 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:50:58,145 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2023-08-21 20:50:58,147 INFO || App info kafka.consumer for connector-consumer-vk_nau26_sink-0 unregistered [org.apache.kafka.common.utils.AppInfoParser] 2023-08-21 20:50:59,690 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors HTTP/1.1" 200 64 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,695 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,695 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,696 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink HTTP/1.1" 200 905 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,698 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,698 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src HTTP/1.1" 200 1528 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,699 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink/status HTTP/1.1" 200 3024 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,701 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src/status HTTP/1.1" 200 168 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,701 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,702 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,703 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,704 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src/config HTTP/1.1" 200 1431 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,704 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink/config HTTP/1.1" 200 808 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,705 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,705 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,707 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,708 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,708 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src/tasks HTTP/1.1" 200 1551 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,709 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink/tasks HTTP/1.1" 200 929 "-" "ReactorNetty/1.1.6" 4 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,710 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,711 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau25_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,712 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src/tasks/0/status HTTP/1.1" 200 56 "-" "ReactorNetty/1.1.6" 3 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,713 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink/tasks/0/status HTTP/1.1" 200 2913 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,714 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau26_src/topics HTTP/1.1" 200 85 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:50:59,714 INFO || 10.0.18.150 - - [21/Aug/2023:17:50:59 +0000] "GET /connectors/vk_nau24_sink/topics HTTP/1.1" 200 75 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:03,775 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:03 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:03,775 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:03 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:03,778 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:03 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:03,778 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:03 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:05,862 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:05 +0000] "GET /connectors/vk_nau26_sink/config HTTP/1.1" 200 809 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:10,331 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:10 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:10,333 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:10 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:33,550 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:33 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:33,552 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:33 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:33,554 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:33 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:51:33,556 INFO || 10.0.18.150 - - [21/Aug/2023:17:51:33 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:32,457 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:32 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:32,457 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:32 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:32,460 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:32 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:32,460 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:32 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:47,502 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:47 +0000] "GET /connectors/vk_nau26_sink HTTP/1.1" 200 906 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:47,503 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:47 +0000] "GET /connectors/vk_nau26_sink/tasks HTTP/1.1" 200 930 "-" "ReactorNetty/1.1.6" 2 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:47,504 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:47 +0000] "GET /connectors/vk_nau26_sink/status HTTP/1.1" 200 2352 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer] 2023-08-21 20:52:47,505 INFO || 10.0.18.18 - - [21/Aug/2023:17:52:47 +0000] "GET /connectors/vk_nau26_sink/tasks/0/status HTTP/1.1" 200 2241 "-" "ReactorNetty/1.1.6" 1 [org.apache.kafka.connect.runtime.rest.RestServer]