2022-12-26 08:14:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/0/logs.log
2022-12-26 08:14:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:14:43 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:14:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:14:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:14:44 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:14:44 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-check-6-0-whmwf with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:14:44 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/0 --log-driver none --name source-mssql-check-6-0-whmwf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 check --config source_config.json
2022-12-26 08:14:44 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:14:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:14:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {check=null, config=source_config.json}
2022-12-26 08:14:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:14:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: CHECK
2022-12-26 08:14:52 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:14:53 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:14:53 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:14:53 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting connection with method: NO_TUNNEL
2022-12-26 08:14:54 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting...
2022-12-26 08:14:54 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed.
2022-12-26 08:14:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to get metadata from the database to see if we can connect.
2022-12-26 08:14:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown initiated...
2022-12-26 08:14:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown completed.
2022-12-26 08:14:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:14:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:14:57 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:57 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:14:57 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:14:57 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:58 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/0/logs.log
2022-12-26 08:14:58 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:14:58 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:14:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:14:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:14:58 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:15:01 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-check-6-0-lovjl with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:15:01 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/0 --log-driver none --name destination-kafka-check-6-0-lovjl --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 check --config source_config.json
2022-12-26 08:15:01 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:15:01 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:15:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:11 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:11 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-12-26 08:15:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2022-12-26 08:15:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:15:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:12 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:12 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:12 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:15:12 [32mINFO[m i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:13 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:15:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:15:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:15:13 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:15:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/0/logs.log
2022-12-26 08:15:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:15:14 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:15:15 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:15:15 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2022-12-26 08:15:15 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2022-12-26 08:15:15 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:15:15 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 6 attempt id: 0
2022-12-26 08:15:15 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {dbo.customers=full_refresh - append}
2022-12-26 08:15:15 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:15:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-write-6-0-qzkwk with resources io.airbyte.config.ResourceRequirements@72fb7fe9[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:15:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/0 --log-driver none --name destination-kafka-write-6-0-qzkwk --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 write --config destination_config.json --catalog destination_catalog.json
2022-12-26 08:15:15 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2022-12-26 08:15:15 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:15:15 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:15:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-read-6-0-xpwgj with resources io.airbyte.config.ResourceRequirements@61b10cbf[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:15:15 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/0 --log-driver none --name source-mssql-read-6-0-xpwgj --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-12-26 08:15:15 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:15:15 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2022-12-26 08:15:15 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2022-12-26 08:15:15 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2022-12-26 08:15:23 [43mdestination[0m > 2022-12-26 08:15:23 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:25 [43mdestination[0m > 2022-12-26 08:15:25 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-12-26 08:15:25 [43mdestination[0m > 2022-12-26 08:15:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:15:25 [43mdestination[0m > 2022-12-26 08:15:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE
2022-12-26 08:15:25 [43mdestination[0m > 2022-12-26 08:15:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-12-26 08:15:26 [43mdestination[0m > 2022-12-26 08:15:26 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:26 [43mdestination[0m > 2022-12-26 08:15:26 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:26 [43mdestination[0m > 2022-12-26 08:15:26 [32mINFO[m i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2022-12-26 08:15:27 [44msource[0m > starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:28 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:29 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:29 [43mdestination[0m > 2022-12-26 08:15:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:29 [44msource[0m > integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-12-26 08:15:29 [44msource[0m > Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:15:29 [44msource[0m > Command: READ
2022-12-26 08:15:29 [44msource[0m > Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-12-26 08:15:29 [43mdestination[0m > 2022-12-26 08:15:29 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:29 [43mdestination[0m > 2022-12-26 08:15:29 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:30 [44msource[0m > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:30 [44msource[0m > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:15:30 [43mdestination[0m > 2022-12-26 08:15:30 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:30 [43mdestination[0m > 2022-12-26 08:15:30 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:32 [44msource[0m > Starting connection with method: NO_TUNNEL
2022-12-26 08:15:32 [43mdestination[0m > 2022-12-26 08:15:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:32 [43mdestination[0m > 2022-12-26 08:15:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:32 [44msource[0m > Legacy state manager selected to manage state object with type LEGACY.
2022-12-26 08:15:32 [44msource[0m > No cursor field set in catalog but not present in state. Stream: dbo_customers, New Cursor Field: null. Resetting cursor value
2022-12-26 08:15:32 [44msource[0m > Initialized CDC state with: null
2022-12-26 08:15:32 [44msource[0m > HikariPool-1 - Starting...
2022-12-26 08:15:32 [44msource[0m > HikariPool-1 - Start completed.
2022-12-26 08:15:33 [43mdestination[0m > 2022-12-26 08:15:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:33 [43mdestination[0m > 2022-12-26 08:15:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:34 [43mdestination[0m > 2022-12-26 08:15:34 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:34 [43mdestination[0m > 2022-12-26 08:15:34 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:34 [44msource[0m > Internal schemas to exclude: [spt_fallback_db, spt_monitor, cdc, spt_values, INFORMATION_SCHEMA, spt_fallback_usg, MSreplication_options, sys, spt_fallback_dev]
2022-12-26 08:15:35 [43mdestination[0m > 2022-12-26 08:15:35 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:35 [43mdestination[0m > 2022-12-26 08:15:35 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:36 [43mdestination[0m > 2022-12-26 08:15:36 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:36 [43mdestination[0m > 2022-12-26 08:15:36 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:37 [43mdestination[0m > 2022-12-26 08:15:37 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:37 [43mdestination[0m > 2022-12-26 08:15:37 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:38 [43mdestination[0m > 2022-12-26 08:15:38 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:38 [43mdestination[0m > 2022-12-26 08:15:38 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:39 [43mdestination[0m > 2022-12-26 08:15:39 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:39 [43mdestination[0m > 2022-12-26 08:15:39 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:40 [44msource[0m > Table customers column id (type int identity[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:15:40 [44msource[0m > Table customers column first_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:15:40 [44msource[0m > Table customers column last_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:15:40 [44msource[0m > Table customers column email (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:15:40 [44msource[0m > Table systranschemas column tabid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:15:40 [44msource[0m > Table systranschemas column startlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:15:40 [44msource[0m > Table systranschemas column endlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:15:40 [44msource[0m > Table systranschemas column typeid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:15:40 [44msource[0m > using CDC: false
2022-12-26 08:15:40 [44msource[0m > Queueing query for table: customers
2022-12-26 08:15:40 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:15:40 [44msource[0m > Prepared SQL query for TableFullRefresh is: SELECT "id", "first_name", "last_name", "email" FROM "dbo"."customers"
2022-12-26 08:15:40 [43mdestination[0m > 2022-12-26 08:15:40 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:40 [43mdestination[0m > 2022-12-26 08:15:40 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:40 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:15:40 [44msource[0m > Closing database connection pool.
2022-12-26 08:15:40 [44msource[0m > HikariPool-1 - Shutdown initiated...
2022-12-26 08:15:40 [44msource[0m > HikariPool-1 - Shutdown completed.
2022-12-26 08:15:40 [44msource[0m > Closed database connection pool.
2022-12-26 08:15:40 [44msource[0m > Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:15:40 [44msource[0m > completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:15:41 [43mdestination[0m > 2022-12-26 08:15:41 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:41 [43mdestination[0m > 2022-12-26 08:15:41 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:42 [43mdestination[0m > 2022-12-26 08:15:42 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:42 [43mdestination[0m > 2022-12-26 08:15:42 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):350 - Source has no more messages, closing connection.
2022-12-26 08:15:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):359 - Total records read: 5 (454 bytes)
2022-12-26 08:15:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):239 - One of source or destination thread complete. Waiting on the other.
2022-12-26 08:15:43 [43mdestination[0m > 2022-12-26 08:15:43 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:43 [43mdestination[0m > 2022-12-26 08:15:43 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:44 [43mdestination[0m > 2022-12-26 08:15:44 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:44 [43mdestination[0m > 2022-12-26 08:15:44 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:45 [43mdestination[0m > 2022-12-26 08:15:45 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:45 [43mdestination[0m > 2022-12-26 08:15:45 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:47 [43mdestination[0m > 2022-12-26 08:15:47 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:47 [43mdestination[0m > 2022-12-26 08:15:47 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:47 [43mdestination[0m > 2022-12-26 08:15:47 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:47 [43mdestination[0m > 2022-12-26 08:15:47 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:49 [43mdestination[0m > 2022-12-26 08:15:49 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:49 [43mdestination[0m > 2022-12-26 08:15:49 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:50 [43mdestination[0m > 2022-12-26 08:15:50 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:50 [43mdestination[0m > 2022-12-26 08:15:50 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:51 [43mdestination[0m > 2022-12-26 08:15:51 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:51 [43mdestination[0m > 2022-12-26 08:15:51 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:52 [43mdestination[0m > 2022-12-26 08:15:52 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:52 [43mdestination[0m > 2022-12-26 08:15:52 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:53 [43mdestination[0m > 2022-12-26 08:15:53 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:53 [43mdestination[0m > 2022-12-26 08:15:53 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:54 [43mdestination[0m > 2022-12-26 08:15:54 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:54 [43mdestination[0m > 2022-12-26 08:15:54 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:55 [43mdestination[0m > 2022-12-26 08:15:55 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:55 [43mdestination[0m > 2022-12-26 08:15:55 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:56 [43mdestination[0m > 2022-12-26 08:15:56 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:56 [43mdestination[0m > 2022-12-26 08:15:56 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:57 [43mdestination[0m > 2022-12-26 08:15:57 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:57 [43mdestination[0m > 2022-12-26 08:15:57 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:15:58 [43mdestination[0m > 2022-12-26 08:15:58 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:15:58 [43mdestination[0m > 2022-12-26 08:15:58 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:00 [43mdestination[0m > 2022-12-26 08:15:59 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:00 [43mdestination[0m > 2022-12-26 08:15:59 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:01 [43mdestination[0m > 2022-12-26 08:16:00 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:01 [43mdestination[0m > 2022-12-26 08:16:00 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:02 [43mdestination[0m > 2022-12-26 08:16:02 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:02 [43mdestination[0m > 2022-12-26 08:16:02 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:02 [43mdestination[0m > 2022-12-26 08:16:02 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:02 [43mdestination[0m > 2022-12-26 08:16:02 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:03 [43mdestination[0m > 2022-12-26 08:16:03 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:03 [43mdestination[0m > 2022-12-26 08:16:03 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:05 [43mdestination[0m > 2022-12-26 08:16:05 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:05 [43mdestination[0m > 2022-12-26 08:16:05 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:05 [43mdestination[0m > 2022-12-26 08:16:05 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:05 [43mdestination[0m > 2022-12-26 08:16:05 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:06 [43mdestination[0m > 2022-12-26 08:16:06 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:06 [43mdestination[0m > 2022-12-26 08:16:06 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:08 [43mdestination[0m > 2022-12-26 08:16:08 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:08 [43mdestination[0m > 2022-12-26 08:16:08 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:08 [43mdestination[0m > 2022-12-26 08:16:08 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:08 [43mdestination[0m > 2022-12-26 08:16:08 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:10 [43mdestination[0m > 2022-12-26 08:16:10 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:10 [43mdestination[0m > 2022-12-26 08:16:10 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:11 [43mdestination[0m > 2022-12-26 08:16:11 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:11 [43mdestination[0m > 2022-12-26 08:16:11 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:12 [43mdestination[0m > 2022-12-26 08:16:12 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:12 [43mdestination[0m > 2022-12-26 08:16:12 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:13 [43mdestination[0m > 2022-12-26 08:16:13 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:13 [43mdestination[0m > 2022-12-26 08:16:13 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:14 [43mdestination[0m > 2022-12-26 08:16:14 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:14 [43mdestination[0m > 2022-12-26 08:16:14 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:15 [43mdestination[0m > 2022-12-26 08:16:15 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:15 [43mdestination[0m > 2022-12-26 08:16:15 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:16 [43mdestination[0m > 2022-12-26 08:16:16 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:16 [43mdestination[0m > 2022-12-26 08:16:16 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:17 [43mdestination[0m > 2022-12-26 08:16:17 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:17 [43mdestination[0m > 2022-12-26 08:16:17 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:18 [43mdestination[0m > 2022-12-26 08:16:18 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:18 [43mdestination[0m > 2022-12-26 08:16:18 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:19 [43mdestination[0m > 2022-12-26 08:16:19 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:19 [43mdestination[0m > 2022-12-26 08:16:19 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:20 [43mdestination[0m > 2022-12-26 08:16:20 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:20 [43mdestination[0m > 2022-12-26 08:16:20 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:21 [43mdestination[0m > 2022-12-26 08:16:20 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:21 [43mdestination[0m > 2022-12-26 08:16:20 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:22 [43mdestination[0m > 2022-12-26 08:16:22 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:22 [43mdestination[0m > 2022-12-26 08:16:22 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:23 [43mdestination[0m > 2022-12-26 08:16:23 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:23 [43mdestination[0m > 2022-12-26 08:16:23 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:24 [43mdestination[0m > 2022-12-26 08:16:24 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:24 [43mdestination[0m > 2022-12-26 08:16:24 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:25 [43mdestination[0m > 2022-12-26 08:16:25 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:25 [43mdestination[0m > 2022-12-26 08:16:25 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:26 [43mdestination[0m > 2022-12-26 08:16:26 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:26 [43mdestination[0m > 2022-12-26 08:16:26 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:27 [43mdestination[0m > 2022-12-26 08:16:27 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:27 [43mdestination[0m > 2022-12-26 08:16:27 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:28 [43mdestination[0m > 2022-12-26 08:16:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:28 [43mdestination[0m > 2022-12-26 08:16:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:29 [43mdestination[0m > 2022-12-26 08:16:29 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:29 [43mdestination[0m > 2022-12-26 08:16:29 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:30 [43mdestination[0m > 2022-12-26 08:16:30 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:30 [43mdestination[0m > 2022-12-26 08:16:30 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:31 [43mdestination[0m > 2022-12-26 08:16:31 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:31 [43mdestination[0m > 2022-12-26 08:16:31 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:32 [43mdestination[0m > 2022-12-26 08:16:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:32 [43mdestination[0m > 2022-12-26 08:16:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:33 [43mdestination[0m > 2022-12-26 08:16:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:33 [43mdestination[0m > 2022-12-26 08:16:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:34 [43mdestination[0m > 2022-12-26 08:16:34 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:34 [43mdestination[0m > 2022-12-26 08:16:34 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:35 [43mdestination[0m > 2022-12-26 08:16:35 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:35 [43mdestination[0m > 2022-12-26 08:16:35 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:36 [43mdestination[0m > 2022-12-26 08:16:36 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:36 [43mdestination[0m > 2022-12-26 08:16:36 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:37 [43mdestination[0m > 2022-12-26 08:16:37 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:37 [43mdestination[0m > 2022-12-26 08:16:37 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:38 [43mdestination[0m > 2022-12-26 08:16:38 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:38 [43mdestination[0m > 2022-12-26 08:16:38 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:39 [43mdestination[0m > 2022-12-26 08:16:39 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:39 [43mdestination[0m > 2022-12-26 08:16:39 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:40 [43mdestination[0m > 2022-12-26 08:16:40 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:40 [43mdestination[0m > 2022-12-26 08:16:40 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:41 [43mdestination[0m > 2022-12-26 08:16:41 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:41 [43mdestination[0m > 2022-12-26 08:16:41 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:42 [43mdestination[0m > 2022-12-26 08:16:42 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:42 [43mdestination[0m > 2022-12-26 08:16:42 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:43 [43mdestination[0m > 2022-12-26 08:16:43 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:16:43 [43mdestination[0m > 2022-12-26 08:16:43 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:16:44 [43mdestination[0m > 2022-12-26 08:16:44 [1;31mERROR[m i.a.i.d.k.KafkaRecordConsumer(lambda$sendRecord$2):93 - Error sending message to topic.
2022-12-26 08:16:44 [43mdestination[0m > org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:16:44 [43mdestination[0m > 2022-12-26 08:16:44 [1;31mERROR[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):49 - Exception while accepting message
2022-12-26 08:16:44 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) [io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:16:44 [43mdestination[0m > 2022-12-26 08:16:44 [33mWARN[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: failed.
2022-12-26 08:16:44 [43mdestination[0m > 2022-12-26 08:16:44 [1;31mERROR[m i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details.
2022-12-26 08:16:44 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:16:44 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:16:44 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):270 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@74c00f53[type=TRACE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=<null>,trace=io.airbyte.protocol.models.AirbyteTraceMessage@7a07efbb[type=ERROR,emittedAt=1.672042604183E12,error=io.airbyte.protocol.models.AirbyteErrorTraceMessage@7e386423[message=Something went wrong in the connector. See the logs for more details.,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,stackTrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,failureType=system_error,additionalProperties={}],estimate=<null>,additionalProperties={}],control=<null>,additionalProperties={}]
2022-12-26 08:16:44 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(replicate):246 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:240) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:124) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	... 1 more
2022-12-26 08:16:44 [32mINFO[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2022-12-26 08:16:44 [33mWARN[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):511 - State capture: No new state, falling back on input state: io.airbyte.config.State@c612acf[state={}]
2022-12-26 08:16:44 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "failed",
  "recordsSynced" : 5,
  "bytesSynced" : 454,
  "startTime" : 1672042515242,
  "endTime" : 1672042604978,
  "totalStats" : {
    "recordsEmitted" : 5,
    "bytesEmitted" : 454,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1672042515242,
    "replicationEndTime" : 1672042604978,
    "sourceReadStartTime" : 1672042515463,
    "sourceReadEndTime" : 1672042542725,
    "destinationWriteStartTime" : 1672042515758,
    "destinationWriteEndTime" : 1672042604971
  },
  "streamStats" : [ {
    "streamName" : "customers",
    "streamNamespace" : "dbo",
    "stats" : {
      "recordsEmitted" : 5,
      "bytesEmitted" : 454
    }
  } ]
}
2022-12-26 08:16:45 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ {
  "failureOrigin" : "destination",
  "failureType" : "system_error",
  "internalMessage" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.",
  "externalMessage" : "Something went wrong in the connector. See the logs for more details.",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 6,
    "from_trace_message" : true,
    "connector_command" : "write"
  },
  "stacktrace" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)\n\tat org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)\n\tat org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)\n\tat io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)\n\tat io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)\n\tat io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)\n\tat io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)\n\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)\n\tat io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)\n\tat io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)\nCaused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.\n",
  "timestamp" : 1672042604183
}, {
  "failureOrigin" : "destination",
  "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1",
  "externalMessage" : "Something went wrong within the destination connector",
  "metadata" : {
    "attemptNumber" : 0,
    "jobId" : 6,
    "connector_command" : "write"
  },
  "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\n\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1589)\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\n",
  "timestamp" : 1672042604971
} ]
2022-12-26 08:16:45 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:16:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:16:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2022-12-26 08:16:45 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:16:45 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):205 - sync summary: io.airbyte.config.StandardSyncOutput@7ec3ed2d[standardSyncSummary=io.airbyte.config.StandardSyncSummary@6bcd9a7e[status=failed,recordsSynced=5,bytesSynced=454,startTime=1672042515242,endTime=1672042604978,totalStats=io.airbyte.config.SyncStats@7a89008c[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,replicationStartTime=1672042515242,replicationEndTime=1672042604978,sourceReadStartTime=1672042515463,sourceReadEndTime=1672042542725,destinationWriteStartTime=1672042515758,destinationWriteEndTime=1672042604971,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@5723c47a[streamName=customers,streamNamespace=dbo,stats=io.airbyte.config.SyncStats@3668f136[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=<null>,destinationStateMessagesEmitted=<null>,recordsCommitted=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,replicationStartTime=<null>,replicationEndTime=<null>,sourceReadStartTime=<null>,sourceReadEndTime=<null>,destinationWriteStartTime=<null>,destinationWriteEndTime=<null>,additionalProperties={}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=io.airbyte.config.State@c612acf[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@317183ef[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@3ce682d[stream=io.airbyte.protocol.models.AirbyteStream@4a077c3a[name=customers,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"last_name":{"type":"string"},"first_name":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=dbo,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@3b97c50d[failureOrigin=destination,failureType=system_error,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@644476b[additionalProperties={attemptNumber=0, jobId=6, from_trace_message=true, connector_command=write}],stacktrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,retryable=<null>,timestamp=1672042604183], io.airbyte.config.FailureReason@76bbc88e[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@7ac8ccf[additionalProperties={attemptNumber=0, jobId=6, connector_command=write}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1589)
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1672042604971]]]
2022-12-26 08:16:45 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):210 - Sync summary length: 5968
2022-12-26 08:16:45 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2022-12-26 08:16:45 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2022-12-26 08:16:45 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2022-12-26 08:16:45 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state
2022-12-26 08:16:47 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/1/logs.log
2022-12-26 08:16:47 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:16:47 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:16:47 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:16:47 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:16:47 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:16:47 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:16:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:16:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-check-6-1-yvebz with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:16:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/1 --log-driver none --name source-mssql-check-6-1-yvebz --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 check --config source_config.json
2022-12-26 08:16:48 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:16:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:16:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {check=null, config=source_config.json}
2022-12-26 08:16:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:16:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: CHECK
2022-12-26 08:16:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:16:57 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:16:57 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:16:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting connection with method: NO_TUNNEL
2022-12-26 08:16:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting...
2022-12-26 08:16:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed.
2022-12-26 08:17:00 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to get metadata from the database to see if we can connect.
2022-12-26 08:17:01 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown initiated...
2022-12-26 08:17:01 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown completed.
2022-12-26 08:17:01 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:17:01 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:17:02 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:02 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/1/logs.log
2022-12-26 08:17:02 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:17:02 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:02 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:17:03 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:17:03 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-check-6-1-wywlf with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:17:03 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/1 --log-driver none --name destination-kafka-check-6-1-wywlf --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 check --config source_config.json
2022-12-26 08:17:03 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:17:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:11 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:11 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-12-26 08:17:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2022-12-26 08:17:11 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:11 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:17:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:12 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:12 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:12 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:12 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:17:12 [32mINFO[m i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:17:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:12 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:17:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/1/logs.log
2022-12-26 08:17:14 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:17:14 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:17:14 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:17:14 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2022-12-26 08:17:14 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2022-12-26 08:17:14 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:17:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 6 attempt id: 1
2022-12-26 08:17:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {dbo.customers=full_refresh - append}
2022-12-26 08:17:14 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:17:14 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-write-6-1-aqdqv with resources io.airbyte.config.ResourceRequirements@4f3a0b68[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:17:14 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/1 --log-driver none --name destination-kafka-write-6-1-aqdqv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 write --config destination_config.json --catalog destination_catalog.json
2022-12-26 08:17:14 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2022-12-26 08:17:14 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:17:14 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:17:14 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-read-6-1-supgd with resources io.airbyte.config.ResourceRequirements@346d3314[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:17:14 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/1 --log-driver none --name source-mssql-read-6-1-supgd --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=1 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-12-26 08:17:14 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:17:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2022-12-26 08:17:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2022-12-26 08:17:14 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2022-12-26 08:17:23 [43mdestination[0m > 2022-12-26 08:17:23 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:23 [44msource[0m > starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:17:25 [43mdestination[0m > 2022-12-26 08:17:25 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-12-26 08:17:25 [43mdestination[0m > 2022-12-26 08:17:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:17:25 [43mdestination[0m > 2022-12-26 08:17:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE
2022-12-26 08:17:25 [43mdestination[0m > 2022-12-26 08:17:25 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-12-26 08:17:27 [44msource[0m > integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-12-26 08:17:27 [44msource[0m > Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:17:27 [44msource[0m > Command: READ
2022-12-26 08:17:27 [44msource[0m > Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-12-26 08:17:28 [43mdestination[0m > 2022-12-26 08:17:28 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:28 [43mdestination[0m > 2022-12-26 08:17:28 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:28 [43mdestination[0m > 2022-12-26 08:17:28 [32mINFO[m i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2022-12-26 08:17:29 [44msource[0m > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:29 [44msource[0m > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:17:31 [44msource[0m > Starting connection with method: NO_TUNNEL
2022-12-26 08:17:32 [44msource[0m > Legacy state manager selected to manage state object with type LEGACY.
2022-12-26 08:17:32 [44msource[0m > No cursor field set in catalog but not present in state. Stream: dbo_customers, New Cursor Field: null. Resetting cursor value
2022-12-26 08:17:32 [44msource[0m > Initialized CDC state with: null
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:32 [43mdestination[0m > 2022-12-26 08:17:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:33 [43mdestination[0m > 2022-12-26 08:17:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:33 [43mdestination[0m > 2022-12-26 08:17:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:33 [44msource[0m > HikariPool-1 - Starting...
2022-12-26 08:17:33 [43mdestination[0m > 2022-12-26 08:17:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:33 [43mdestination[0m > 2022-12-26 08:17:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:33 [44msource[0m > HikariPool-1 - Start completed.
2022-12-26 08:17:34 [43mdestination[0m > 2022-12-26 08:17:34 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:34 [43mdestination[0m > 2022-12-26 08:17:34 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:35 [43mdestination[0m > 2022-12-26 08:17:35 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:35 [43mdestination[0m > 2022-12-26 08:17:35 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:36 [44msource[0m > Internal schemas to exclude: [spt_fallback_db, spt_monitor, cdc, spt_values, INFORMATION_SCHEMA, spt_fallback_usg, MSreplication_options, sys, spt_fallback_dev]
2022-12-26 08:17:36 [43mdestination[0m > 2022-12-26 08:17:36 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:36 [43mdestination[0m > 2022-12-26 08:17:36 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:37 [43mdestination[0m > 2022-12-26 08:17:37 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:37 [43mdestination[0m > 2022-12-26 08:17:37 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:38 [43mdestination[0m > 2022-12-26 08:17:38 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:38 [43mdestination[0m > 2022-12-26 08:17:38 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:39 [43mdestination[0m > 2022-12-26 08:17:39 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:39 [43mdestination[0m > 2022-12-26 08:17:39 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:40 [43mdestination[0m > 2022-12-26 08:17:40 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:40 [43mdestination[0m > 2022-12-26 08:17:40 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:41 [44msource[0m > Table customers column id (type int identity[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:17:41 [44msource[0m > Table customers column first_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:17:41 [44msource[0m > Table customers column last_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:17:41 [44msource[0m > Table customers column email (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:17:41 [44msource[0m > Table systranschemas column tabid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:17:41 [44msource[0m > Table systranschemas column startlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:17:41 [44msource[0m > Table systranschemas column endlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:17:41 [44msource[0m > Table systranschemas column typeid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:17:41 [44msource[0m > using CDC: false
2022-12-26 08:17:41 [44msource[0m > Queueing query for table: customers
2022-12-26 08:17:41 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:17:41 [44msource[0m > Prepared SQL query for TableFullRefresh is: SELECT "id", "first_name", "last_name", "email" FROM "dbo"."customers"
2022-12-26 08:17:41 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:17:41 [43mdestination[0m > 2022-12-26 08:17:41 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:41 [43mdestination[0m > 2022-12-26 08:17:41 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:41 [44msource[0m > Closing database connection pool.
2022-12-26 08:17:41 [44msource[0m > HikariPool-1 - Shutdown initiated...
2022-12-26 08:17:41 [44msource[0m > HikariPool-1 - Shutdown completed.
2022-12-26 08:17:41 [44msource[0m > Closed database connection pool.
2022-12-26 08:17:41 [44msource[0m > Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:17:41 [44msource[0m > completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:17:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):359 - Total records read: 5 (454 bytes)
2022-12-26 08:17:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):239 - One of source or destination thread complete. Waiting on the other.
2022-12-26 08:17:42 [43mdestination[0m > 2022-12-26 08:17:42 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:42 [43mdestination[0m > 2022-12-26 08:17:42 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:43 [43mdestination[0m > 2022-12-26 08:17:43 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:43 [43mdestination[0m > 2022-12-26 08:17:43 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:44 [43mdestination[0m > 2022-12-26 08:17:44 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:44 [43mdestination[0m > 2022-12-26 08:17:44 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:45 [43mdestination[0m > 2022-12-26 08:17:45 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:45 [43mdestination[0m > 2022-12-26 08:17:45 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:46 [43mdestination[0m > 2022-12-26 08:17:46 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:46 [43mdestination[0m > 2022-12-26 08:17:46 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:48 [43mdestination[0m > 2022-12-26 08:17:47 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:48 [43mdestination[0m > 2022-12-26 08:17:47 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:49 [43mdestination[0m > 2022-12-26 08:17:49 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:49 [43mdestination[0m > 2022-12-26 08:17:49 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:50 [43mdestination[0m > 2022-12-26 08:17:50 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:50 [43mdestination[0m > 2022-12-26 08:17:50 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:51 [43mdestination[0m > 2022-12-26 08:17:51 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:51 [43mdestination[0m > 2022-12-26 08:17:51 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:52 [43mdestination[0m > 2022-12-26 08:17:52 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:52 [43mdestination[0m > 2022-12-26 08:17:52 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:53 [43mdestination[0m > 2022-12-26 08:17:53 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:53 [43mdestination[0m > 2022-12-26 08:17:53 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:54 [43mdestination[0m > 2022-12-26 08:17:54 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:54 [43mdestination[0m > 2022-12-26 08:17:54 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:55 [43mdestination[0m > 2022-12-26 08:17:55 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:55 [43mdestination[0m > 2022-12-26 08:17:55 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:56 [43mdestination[0m > 2022-12-26 08:17:56 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:56 [43mdestination[0m > 2022-12-26 08:17:56 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:57 [43mdestination[0m > 2022-12-26 08:17:57 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:57 [43mdestination[0m > 2022-12-26 08:17:57 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:17:58 [43mdestination[0m > 2022-12-26 08:17:58 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:17:58 [43mdestination[0m > 2022-12-26 08:17:58 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:00 [43mdestination[0m > 2022-12-26 08:17:59 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:00 [43mdestination[0m > 2022-12-26 08:17:59 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:01 [43mdestination[0m > 2022-12-26 08:18:01 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:01 [43mdestination[0m > 2022-12-26 08:18:01 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:02 [43mdestination[0m > 2022-12-26 08:18:02 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:02 [43mdestination[0m > 2022-12-26 08:18:02 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:03 [43mdestination[0m > 2022-12-26 08:18:03 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:03 [43mdestination[0m > 2022-12-26 08:18:03 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:04 [43mdestination[0m > 2022-12-26 08:18:04 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:04 [43mdestination[0m > 2022-12-26 08:18:04 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:05 [43mdestination[0m > 2022-12-26 08:18:05 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:05 [43mdestination[0m > 2022-12-26 08:18:05 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:06 [43mdestination[0m > 2022-12-26 08:18:06 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:06 [43mdestination[0m > 2022-12-26 08:18:06 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:07 [43mdestination[0m > 2022-12-26 08:18:07 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:07 [43mdestination[0m > 2022-12-26 08:18:07 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:08 [43mdestination[0m > 2022-12-26 08:18:08 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:08 [43mdestination[0m > 2022-12-26 08:18:08 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:09 [43mdestination[0m > 2022-12-26 08:18:09 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:09 [43mdestination[0m > 2022-12-26 08:18:09 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:11 [43mdestination[0m > 2022-12-26 08:18:11 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:11 [43mdestination[0m > 2022-12-26 08:18:11 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:11 [43mdestination[0m > 2022-12-26 08:18:11 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:11 [43mdestination[0m > 2022-12-26 08:18:11 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:12 [43mdestination[0m > 2022-12-26 08:18:12 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:12 [43mdestination[0m > 2022-12-26 08:18:12 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:13 [43mdestination[0m > 2022-12-26 08:18:13 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:13 [43mdestination[0m > 2022-12-26 08:18:13 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:14 [43mdestination[0m > 2022-12-26 08:18:14 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:14 [43mdestination[0m > 2022-12-26 08:18:14 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:15 [43mdestination[0m > 2022-12-26 08:18:15 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:15 [43mdestination[0m > 2022-12-26 08:18:15 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:16 [43mdestination[0m > 2022-12-26 08:18:16 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:16 [43mdestination[0m > 2022-12-26 08:18:16 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:17 [43mdestination[0m > 2022-12-26 08:18:17 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:17 [43mdestination[0m > 2022-12-26 08:18:17 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:18 [43mdestination[0m > 2022-12-26 08:18:18 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:18 [43mdestination[0m > 2022-12-26 08:18:18 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:19 [43mdestination[0m > 2022-12-26 08:18:19 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:19 [43mdestination[0m > 2022-12-26 08:18:19 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:21 [43mdestination[0m > 2022-12-26 08:18:21 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:21 [43mdestination[0m > 2022-12-26 08:18:21 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:22 [43mdestination[0m > 2022-12-26 08:18:22 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:22 [43mdestination[0m > 2022-12-26 08:18:22 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:22 [43mdestination[0m > 2022-12-26 08:18:22 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:22 [43mdestination[0m > 2022-12-26 08:18:22 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:23 [43mdestination[0m > 2022-12-26 08:18:23 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:23 [43mdestination[0m > 2022-12-26 08:18:23 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:25 [43mdestination[0m > 2022-12-26 08:18:25 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:25 [43mdestination[0m > 2022-12-26 08:18:25 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:26 [43mdestination[0m > 2022-12-26 08:18:26 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:26 [43mdestination[0m > 2022-12-26 08:18:26 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:27 [43mdestination[0m > 2022-12-26 08:18:27 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:27 [43mdestination[0m > 2022-12-26 08:18:27 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:28 [43mdestination[0m > 2022-12-26 08:18:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:28 [43mdestination[0m > 2022-12-26 08:18:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:29 [43mdestination[0m > 2022-12-26 08:18:29 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:29 [43mdestination[0m > 2022-12-26 08:18:29 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:30 [43mdestination[0m > 2022-12-26 08:18:30 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:30 [43mdestination[0m > 2022-12-26 08:18:30 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:31 [43mdestination[0m > 2022-12-26 08:18:31 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:31 [43mdestination[0m > 2022-12-26 08:18:31 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:32 [43mdestination[0m > 2022-12-26 08:18:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:32 [43mdestination[0m > 2022-12-26 08:18:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:33 [43mdestination[0m > 2022-12-26 08:18:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:33 [43mdestination[0m > 2022-12-26 08:18:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:34 [43mdestination[0m > 2022-12-26 08:18:34 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:34 [43mdestination[0m > 2022-12-26 08:18:34 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:35 [43mdestination[0m > 2022-12-26 08:18:35 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:35 [43mdestination[0m > 2022-12-26 08:18:35 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:36 [43mdestination[0m > 2022-12-26 08:18:36 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:36 [43mdestination[0m > 2022-12-26 08:18:36 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:37 [43mdestination[0m > 2022-12-26 08:18:37 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:37 [43mdestination[0m > 2022-12-26 08:18:37 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:38 [43mdestination[0m > 2022-12-26 08:18:38 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:38 [43mdestination[0m > 2022-12-26 08:18:38 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:39 [43mdestination[0m > 2022-12-26 08:18:39 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:39 [43mdestination[0m > 2022-12-26 08:18:39 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:40 [43mdestination[0m > 2022-12-26 08:18:40 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:40 [43mdestination[0m > 2022-12-26 08:18:40 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:41 [43mdestination[0m > 2022-12-26 08:18:41 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:41 [43mdestination[0m > 2022-12-26 08:18:41 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [1;31mERROR[m i.a.i.d.k.KafkaRecordConsumer(lambda$sendRecord$2):93 - Error sending message to topic.
2022-12-26 08:18:42 [43mdestination[0m > org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [1;31mERROR[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):49 - Exception while accepting message
2022-12-26 08:18:42 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) [io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [33mWARN[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: failed.
2022-12-26 08:18:42 [43mdestination[0m > 2022-12-26 08:18:42 [1;31mERROR[m i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details.
2022-12-26 08:18:42 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:18:42 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:18:42 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):270 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@17e43992[type=TRACE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=<null>,trace=io.airbyte.protocol.models.AirbyteTraceMessage@1923d51e[type=ERROR,emittedAt=1.672042722914E12,error=io.airbyte.protocol.models.AirbyteErrorTraceMessage@1d1c52e2[message=Something went wrong in the connector. See the logs for more details.,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,stackTrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,failureType=system_error,additionalProperties={}],estimate=<null>,additionalProperties={}],control=<null>,additionalProperties={}]
2022-12-26 08:18:43 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(replicate):246 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:240) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:124) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	... 1 more
2022-12-26 08:18:43 [32mINFO[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2022-12-26 08:18:43 [33mWARN[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):511 - State capture: No new state, falling back on input state: io.airbyte.config.State@c0521d0[state={}]
2022-12-26 08:18:43 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "failed",
  "recordsSynced" : 5,
  "bytesSynced" : 454,
  "startTime" : 1672042634469,
  "endTime" : 1672042723432,
  "totalStats" : {
    "recordsEmitted" : 5,
    "bytesEmitted" : 454,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1672042634469,
    "replicationEndTime" : 1672042723428,
    "sourceReadStartTime" : 1672042634635,
    "sourceReadEndTime" : 1672042662374,
    "destinationWriteStartTime" : 1672042634940,
    "destinationWriteEndTime" : 1672042723425
  },
  "streamStats" : [ {
    "streamName" : "customers",
    "streamNamespace" : "dbo",
    "stats" : {
      "recordsEmitted" : 5,
      "bytesEmitted" : 454
    }
  } ]
}
2022-12-26 08:18:43 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ {
  "failureOrigin" : "destination",
  "failureType" : "system_error",
  "internalMessage" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.",
  "externalMessage" : "Something went wrong in the connector. See the logs for more details.",
  "metadata" : {
    "attemptNumber" : 1,
    "jobId" : 6,
    "from_trace_message" : true,
    "connector_command" : "write"
  },
  "stacktrace" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)\n\tat org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)\n\tat org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)\n\tat io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)\n\tat io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)\n\tat io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)\n\tat io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)\n\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)\n\tat io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)\n\tat io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)\nCaused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.\n",
  "timestamp" : 1672042722914
}, {
  "failureOrigin" : "destination",
  "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1",
  "externalMessage" : "Something went wrong within the destination connector",
  "metadata" : {
    "attemptNumber" : 1,
    "jobId" : 6,
    "connector_command" : "write"
  },
  "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\n\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1589)\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\n",
  "timestamp" : 1672042723426
} ]
2022-12-26 08:18:43 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:18:43 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):205 - sync summary: io.airbyte.config.StandardSyncOutput@4cd31b0a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@31f39864[status=failed,recordsSynced=5,bytesSynced=454,startTime=1672042634469,endTime=1672042723432,totalStats=io.airbyte.config.SyncStats@f0b2529[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,replicationStartTime=1672042634469,replicationEndTime=1672042723428,sourceReadStartTime=1672042634635,sourceReadEndTime=1672042662374,destinationWriteStartTime=1672042634940,destinationWriteEndTime=1672042723425,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@5a0296b4[streamName=customers,streamNamespace=dbo,stats=io.airbyte.config.SyncStats@eddddb5[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=<null>,destinationStateMessagesEmitted=<null>,recordsCommitted=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,replicationStartTime=<null>,replicationEndTime=<null>,sourceReadStartTime=<null>,sourceReadEndTime=<null>,destinationWriteStartTime=<null>,destinationWriteEndTime=<null>,additionalProperties={}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=io.airbyte.config.State@c0521d0[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@234044b2[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@75b40f9e[stream=io.airbyte.protocol.models.AirbyteStream@3b4d90aa[name=customers,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"last_name":{"type":"string"},"first_name":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=dbo,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@5b1dc203[failureOrigin=destination,failureType=system_error,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@7a596806[additionalProperties={attemptNumber=1, jobId=6, from_trace_message=true, connector_command=write}],stacktrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,retryable=<null>,timestamp=1672042722914], io.airbyte.config.FailureReason@2fc4402c[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@78db5dbe[additionalProperties={attemptNumber=1, jobId=6, connector_command=write}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1589)
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1672042723426]]]
2022-12-26 08:18:43 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):210 - Sync summary length: 5969
2022-12-26 08:18:43 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2022-12-26 08:18:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2022-12-26 08:18:43 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:43 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2022-12-26 08:18:43 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2022-12-26 08:18:43 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state
2022-12-26 08:18:46 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/2/logs.log
2022-12-26 08:18:46 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:18:46 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:18:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:18:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:18:47 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:18:47 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-check-6-2-oiyfp with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:18:47 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/2 --log-driver none --name source-mssql-check-6-2-oiyfp --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 check --config source_config.json
2022-12-26 08:18:47 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - integration args: {check=null, config=source_config.json}
2022-12-26 08:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:18:55 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Command: CHECK
2022-12-26 08:18:56 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:18:56 [33mWARN[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):117 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Starting connection with method: NO_TUNNEL
2022-12-26 08:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Starting...
2022-12-26 08:18:57 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Start completed.
2022-12-26 08:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Attempting to get metadata from the database to see if we can connect.
2022-12-26 08:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown initiated...
2022-12-26 08:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - HikariPool-1 - Shutdown completed.
2022-12-26 08:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:18:58 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):120 - completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:18:59 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:59 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:18:59 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:18:59 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:19:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/2/logs.log
2022-12-26 08:19:00 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:19:00 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:19:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2022-12-26 08:19:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:19:00 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:19:00 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-check-6-2-cmist with resources io.airbyte.config.ResourceRequirements@44522141[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:19:00 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/2 --log-driver none --name destination-kafka-check-6-2-cmist --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 check --config source_config.json
2022-12-26 08:19:00 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:19:08 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:08 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: CHECK
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):152 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:09 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(parseJson):78 - 2022-12-26 08:19:09 [32mINFO[m i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:10 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:19:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2022-12-26 08:19:10 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:12 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):136 - Docker volume job log path: /tmp/workspace/6/2/logs.log
2022-12-26 08:19:12 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):141 - Executing worker wrapper. Airbyte version: 0.40.26
2022-12-26 08:19:12 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to save workflow id for cancellation
2022-12-26 08:19:12 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:19:12 [32mINFO[m i.a.c.EnvConfigs(getEnvOrDefault):1161 - Using default value for environment variable METRIC_CLIENT: ''
2022-12-26 08:19:12 [33mWARN[m i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2022-12-26 08:19:12 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2022-12-26 08:19:12 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):142 - start sync worker. job id: 6 attempt id: 2
2022-12-26 08:19:12 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):157 - configured sync modes: {dbo.customers=full_refresh - append}
2022-12-26 08:19:12 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):72 - Running destination...
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/destination-kafka:0.1.10 exists...
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/destination-kafka:0.1.10 was found locally.
2022-12-26 08:19:12 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = destination-kafka-write-6-2-vtunz with resources io.airbyte.config.ResourceRequirements@2f67568d[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:19:12 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/2 --log-driver none --name destination-kafka-write-6-2-vtunz --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.10 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/destination-kafka:0.1.10 write --config destination_config.json --catalog destination_catalog.json
2022-12-26 08:19:12 [32mINFO[m i.a.w.i.VersionedAirbyteMessageBufferedWriterFactory(createWriter):33 - Writing messages to protocol version 0.2.0
2022-12-26 08:19:12 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-mssql:0.4.26 exists...
2022-12-26 08:19:12 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-mssql:0.4.26 was found locally.
2022-12-26 08:19:12 [32mINFO[m i.a.w.p.DockerProcessFactory(create):120 - Creating docker container = source-mssql-read-6-2-vavoi with resources io.airbyte.config.ResourceRequirements@7e42e7f7[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2022-12-26 08:19:12 [32mINFO[m i.a.w.p.DockerProcessFactory(create):164 - Preparing command: docker run --rm --init -i -w /data/6/2 --log-driver none --name source-mssql-read-6-2-vavoi --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_JOB_ATTEMPT=2 -e WORKER_CONNECTOR_IMAGE=airbyte/source-mssql:0.4.26 -e AUTO_DETECT_SCHEMA=false -e AIRBYTE_VERSION=0.40.26 -e WORKER_JOB_ID=6 airbyte/source-mssql:0.4.26 read --config source_config.json --catalog source_catalog.json --state input_state.json
2022-12-26 08:19:12 [32mINFO[m i.a.w.i.VersionedAirbyteStreamFactory(create):97 - Reading messages from protocol version 0.2.0
2022-12-26 08:19:12 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):260 - Destination output thread started.
2022-12-26 08:19:12 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):234 - Waiting for source and destination threads to complete.
2022-12-26 08:19:12 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):310 - Replication thread started.
2022-12-26 08:19:21 [43mdestination[0m > 2022-12-26 08:19:21 [32mINFO[m i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:21 [44msource[0m > starting source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:19:22 [43mdestination[0m > 2022-12-26 08:19:22 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-12-26 08:19:22 [43mdestination[0m > 2022-12-26 08:19:22 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):104 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-12-26 08:19:22 [43mdestination[0m > 2022-12-26 08:19:22 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):105 - Command: WRITE
2022-12-26 08:19:22 [43mdestination[0m > 2022-12-26 08:19:22 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):106 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-12-26 08:19:22 [44msource[0m > integration args: {read=null, catalog=source_catalog.json, state=input_state.json, config=source_config.json}
2022-12-26 08:19:22 [44msource[0m > Running integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:19:22 [44msource[0m > Command: READ
2022-12-26 08:19:22 [44msource[0m > Integration config: IntegrationConfig{command=READ, configPath='source_config.json', catalogPath='source_catalog.json', statePath='input_state.json'}
2022-12-26 08:19:22 [43mdestination[0m > 2022-12-26 08:19:22 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:23 [43mdestination[0m > 2022-12-26 08:19:23 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:23 [43mdestination[0m > 2022-12-26 08:19:23 [32mINFO[m i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2022-12-26 08:19:23 [44msource[0m > Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:23 [43mdestination[0m > 2022-12-26 08:19:23 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:23 [43mdestination[0m > 2022-12-26 08:19:23 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:23 [44msource[0m > Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-12-26 08:19:23 [43mdestination[0m > 2022-12-26 08:19:23 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:23 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:24 [44msource[0m > Starting connection with method: NO_TUNNEL
2022-12-26 08:19:24 [44msource[0m > Legacy state manager selected to manage state object with type LEGACY.
2022-12-26 08:19:24 [44msource[0m > No cursor field set in catalog but not present in state. Stream: dbo_customers, New Cursor Field: null. Resetting cursor value
2022-12-26 08:19:24 [44msource[0m > Initialized CDC state with: null
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:24 [43mdestination[0m > 2022-12-26 08:19:24 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:25 [44msource[0m > HikariPool-1 - Starting...
2022-12-26 08:19:25 [44msource[0m > HikariPool-1 - Start completed.
2022-12-26 08:19:25 [43mdestination[0m > 2022-12-26 08:19:25 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:25 [43mdestination[0m > 2022-12-26 08:19:25 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:26 [44msource[0m > Internal schemas to exclude: [spt_fallback_db, spt_monitor, cdc, spt_values, INFORMATION_SCHEMA, spt_fallback_usg, MSreplication_options, sys, spt_fallback_dev]
2022-12-26 08:19:26 [43mdestination[0m > 2022-12-26 08:19:26 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:26 [43mdestination[0m > 2022-12-26 08:19:26 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:27 [43mdestination[0m > 2022-12-26 08:19:27 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:27 [43mdestination[0m > 2022-12-26 08:19:27 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:28 [43mdestination[0m > 2022-12-26 08:19:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:28 [43mdestination[0m > 2022-12-26 08:19:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:29 [43mdestination[0m > 2022-12-26 08:19:29 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:29 [43mdestination[0m > 2022-12-26 08:19:29 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:31 [43mdestination[0m > 2022-12-26 08:19:30 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:31 [43mdestination[0m > 2022-12-26 08:19:30 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:31 [44msource[0m > Table customers column id (type int identity[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:19:31 [44msource[0m > Table customers column first_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:19:31 [44msource[0m > Table customers column last_name (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:19:31 [44msource[0m > Table customers column email (type varchar[255], nullable false) -> JsonSchemaType({type=string})
2022-12-26 08:19:31 [44msource[0m > Table systranschemas column tabid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:19:31 [44msource[0m > Table systranschemas column startlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:19:31 [44msource[0m > Table systranschemas column endlsn (type binary[10], nullable false) -> JsonSchemaType({type=string, contentEncoding=base64})
2022-12-26 08:19:31 [44msource[0m > Table systranschemas column typeid (type int[10], nullable false) -> JsonSchemaType({type=number, airbyte_type=integer})
2022-12-26 08:19:31 [44msource[0m > using CDC: false
2022-12-26 08:19:31 [44msource[0m > Queueing query for table: customers
2022-12-26 08:19:31 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:19:31 [44msource[0m > Prepared SQL query for TableFullRefresh is: SELECT "id", "first_name", "last_name", "email" FROM "dbo"."customers"
2022-12-26 08:19:31 [44msource[0m > Set initial fetch size: 10 rows
2022-12-26 08:19:32 [44msource[0m > Closing database connection pool.
2022-12-26 08:19:32 [44msource[0m > HikariPool-1 - Shutdown initiated...
2022-12-26 08:19:32 [43mdestination[0m > 2022-12-26 08:19:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:32 [43mdestination[0m > 2022-12-26 08:19:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:32 [44msource[0m > HikariPool-1 - Shutdown completed.
2022-12-26 08:19:32 [44msource[0m > Closed database connection pool.
2022-12-26 08:19:32 [44msource[0m > Completed integration: io.airbyte.integrations.base.ssh.SshWrappedSource
2022-12-26 08:19:32 [44msource[0m > completed source: class io.airbyte.integrations.source.mssql.MssqlSource
2022-12-26 08:19:33 [43mdestination[0m > 2022-12-26 08:19:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:33 [43mdestination[0m > 2022-12-26 08:19:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:33 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromSrcAndWriteToDstRunnable$6):359 - Total records read: 5 (454 bytes)
2022-12-26 08:19:33 [32mINFO[m i.a.w.g.DefaultReplicationWorker(replicate):239 - One of source or destination thread complete. Waiting on the other.
2022-12-26 08:19:34 [43mdestination[0m > 2022-12-26 08:19:34 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:34 [43mdestination[0m > 2022-12-26 08:19:34 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:35 [43mdestination[0m > 2022-12-26 08:19:35 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:35 [43mdestination[0m > 2022-12-26 08:19:35 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:36 [43mdestination[0m > 2022-12-26 08:19:36 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:36 [43mdestination[0m > 2022-12-26 08:19:36 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:37 [43mdestination[0m > 2022-12-26 08:19:37 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:37 [43mdestination[0m > 2022-12-26 08:19:37 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:38 [43mdestination[0m > 2022-12-26 08:19:38 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:38 [43mdestination[0m > 2022-12-26 08:19:38 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:39 [43mdestination[0m > 2022-12-26 08:19:39 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:39 [43mdestination[0m > 2022-12-26 08:19:39 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:40 [43mdestination[0m > 2022-12-26 08:19:40 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:40 [43mdestination[0m > 2022-12-26 08:19:40 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:41 [43mdestination[0m > 2022-12-26 08:19:41 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:41 [43mdestination[0m > 2022-12-26 08:19:41 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:42 [43mdestination[0m > 2022-12-26 08:19:42 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:42 [43mdestination[0m > 2022-12-26 08:19:42 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:43 [43mdestination[0m > 2022-12-26 08:19:43 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:43 [43mdestination[0m > 2022-12-26 08:19:43 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:44 [43mdestination[0m > 2022-12-26 08:19:44 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:44 [43mdestination[0m > 2022-12-26 08:19:44 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:45 [43mdestination[0m > 2022-12-26 08:19:45 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:45 [43mdestination[0m > 2022-12-26 08:19:45 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:46 [43mdestination[0m > 2022-12-26 08:19:46 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:46 [43mdestination[0m > 2022-12-26 08:19:46 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:47 [43mdestination[0m > 2022-12-26 08:19:47 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:47 [43mdestination[0m > 2022-12-26 08:19:47 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:48 [43mdestination[0m > 2022-12-26 08:19:48 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:48 [43mdestination[0m > 2022-12-26 08:19:48 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:49 [43mdestination[0m > 2022-12-26 08:19:49 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:49 [43mdestination[0m > 2022-12-26 08:19:49 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:50 [43mdestination[0m > 2022-12-26 08:19:50 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:50 [43mdestination[0m > 2022-12-26 08:19:50 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:51 [43mdestination[0m > 2022-12-26 08:19:51 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:51 [43mdestination[0m > 2022-12-26 08:19:51 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:52 [43mdestination[0m > 2022-12-26 08:19:52 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:52 [43mdestination[0m > 2022-12-26 08:19:52 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:53 [43mdestination[0m > 2022-12-26 08:19:53 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:53 [43mdestination[0m > 2022-12-26 08:19:53 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:54 [43mdestination[0m > 2022-12-26 08:19:54 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:54 [43mdestination[0m > 2022-12-26 08:19:54 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:55 [43mdestination[0m > 2022-12-26 08:19:55 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:55 [43mdestination[0m > 2022-12-26 08:19:55 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:56 [43mdestination[0m > 2022-12-26 08:19:56 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:56 [43mdestination[0m > 2022-12-26 08:19:56 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:57 [43mdestination[0m > 2022-12-26 08:19:57 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:57 [43mdestination[0m > 2022-12-26 08:19:57 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:58 [43mdestination[0m > 2022-12-26 08:19:58 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:58 [43mdestination[0m > 2022-12-26 08:19:58 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:19:59 [43mdestination[0m > 2022-12-26 08:19:59 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:19:59 [43mdestination[0m > 2022-12-26 08:19:59 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:00 [43mdestination[0m > 2022-12-26 08:20:00 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:00 [43mdestination[0m > 2022-12-26 08:20:00 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:01 [43mdestination[0m > 2022-12-26 08:20:01 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:01 [43mdestination[0m > 2022-12-26 08:20:01 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:02 [43mdestination[0m > 2022-12-26 08:20:02 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:02 [43mdestination[0m > 2022-12-26 08:20:02 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:03 [43mdestination[0m > 2022-12-26 08:20:03 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:03 [43mdestination[0m > 2022-12-26 08:20:03 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:04 [43mdestination[0m > 2022-12-26 08:20:04 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:04 [43mdestination[0m > 2022-12-26 08:20:04 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:05 [43mdestination[0m > 2022-12-26 08:20:05 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:05 [43mdestination[0m > 2022-12-26 08:20:05 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:06 [43mdestination[0m > 2022-12-26 08:20:06 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:06 [43mdestination[0m > 2022-12-26 08:20:06 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:07 [43mdestination[0m > 2022-12-26 08:20:07 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:07 [43mdestination[0m > 2022-12-26 08:20:07 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:08 [43mdestination[0m > 2022-12-26 08:20:08 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:08 [43mdestination[0m > 2022-12-26 08:20:08 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:09 [43mdestination[0m > 2022-12-26 08:20:09 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:09 [43mdestination[0m > 2022-12-26 08:20:09 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:10 [43mdestination[0m > 2022-12-26 08:20:10 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:10 [43mdestination[0m > 2022-12-26 08:20:10 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:11 [43mdestination[0m > 2022-12-26 08:20:11 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:11 [43mdestination[0m > 2022-12-26 08:20:11 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:12 [43mdestination[0m > 2022-12-26 08:20:12 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:12 [43mdestination[0m > 2022-12-26 08:20:12 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:13 [43mdestination[0m > 2022-12-26 08:20:13 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:13 [43mdestination[0m > 2022-12-26 08:20:13 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:15 [43mdestination[0m > 2022-12-26 08:20:15 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:15 [43mdestination[0m > 2022-12-26 08:20:15 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:16 [43mdestination[0m > 2022-12-26 08:20:16 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:16 [43mdestination[0m > 2022-12-26 08:20:16 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:17 [43mdestination[0m > 2022-12-26 08:20:17 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:17 [43mdestination[0m > 2022-12-26 08:20:17 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:18 [43mdestination[0m > 2022-12-26 08:20:18 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:18 [43mdestination[0m > 2022-12-26 08:20:18 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:19 [43mdestination[0m > 2022-12-26 08:20:19 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:19 [43mdestination[0m > 2022-12-26 08:20:19 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:20 [43mdestination[0m > 2022-12-26 08:20:20 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:20 [43mdestination[0m > 2022-12-26 08:20:20 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:21 [43mdestination[0m > 2022-12-26 08:20:21 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:21 [43mdestination[0m > 2022-12-26 08:20:21 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:22 [43mdestination[0m > 2022-12-26 08:20:22 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:22 [43mdestination[0m > 2022-12-26 08:20:22 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:23 [43mdestination[0m > 2022-12-26 08:20:23 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:23 [43mdestination[0m > 2022-12-26 08:20:23 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:24 [43mdestination[0m > 2022-12-26 08:20:24 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:24 [43mdestination[0m > 2022-12-26 08:20:24 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:25 [43mdestination[0m > 2022-12-26 08:20:25 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:25 [43mdestination[0m > 2022-12-26 08:20:25 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:26 [43mdestination[0m > 2022-12-26 08:20:26 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:26 [43mdestination[0m > 2022-12-26 08:20:26 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:27 [43mdestination[0m > 2022-12-26 08:20:27 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:27 [43mdestination[0m > 2022-12-26 08:20:27 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:28 [43mdestination[0m > 2022-12-26 08:20:28 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:28 [43mdestination[0m > 2022-12-26 08:20:28 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:29 [43mdestination[0m > 2022-12-26 08:20:29 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:29 [43mdestination[0m > 2022-12-26 08:20:29 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:30 [43mdestination[0m > 2022-12-26 08:20:30 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:30 [43mdestination[0m > 2022-12-26 08:20:30 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:31 [43mdestination[0m > 2022-12-26 08:20:31 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:31 [43mdestination[0m > 2022-12-26 08:20:31 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:32 [43mdestination[0m > 2022-12-26 08:20:32 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:32 [43mdestination[0m > 2022-12-26 08:20:32 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:33 [43mdestination[0m > 2022-12-26 08:20:33 [33mWARN[m o.a.k.c.NetworkClient(processDisconnection):776 - [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2022-12-26 08:20:33 [43mdestination[0m > 2022-12-26 08:20:33 [33mWARN[m o.a.k.c.NetworkClient$DefaultMetadataUpdater(handleServerDisconnect):1060 - [Producer clientId=producer-1] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected
2022-12-26 08:20:34 [43mdestination[0m > 2022-12-26 08:20:33 [1;31mERROR[m i.a.i.d.k.KafkaRecordConsumer(lambda$sendRecord$2):93 - Error sending message to topic.
2022-12-26 08:20:34 [43mdestination[0m > org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:20:34 [43mdestination[0m > 2022-12-26 08:20:33 [1;31mERROR[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(accept):49 - Exception while accepting message
2022-12-26 08:20:34 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) [io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) [io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:20:34 [43mdestination[0m > 2022-12-26 08:20:34 [33mWARN[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - Airbyte message consumer: failed.
2022-12-26 08:20:34 [43mdestination[0m > 2022-12-26 08:20:34 [1;31mERROR[m i.a.i.b.AirbyteExceptionHandler(uncaughtException):26 - Something went wrong in the connector. See the logs for more details.
2022-12-26 08:20:34 [43mdestination[0m > java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885) ~[kafka-clients-2.8.0.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97) ~[io.airbyte.airbyte-integrations.bases-base-java-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > 	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85) ~[io.airbyte.airbyte-integrations.connectors-destination-kafka-0.39.41-alpha.jar:?]
2022-12-26 08:20:34 [43mdestination[0m > Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
2022-12-26 08:20:34 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$readFromDstRunnable$4):270 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@d7b4593[type=TRACE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=<null>,trace=io.airbyte.protocol.models.AirbyteTraceMessage@3bcaa4c[type=ERROR,emittedAt=1.672042834067E12,error=io.airbyte.protocol.models.AirbyteErrorTraceMessage@7832ee3[message=Something went wrong in the connector. See the logs for more details.,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,stackTrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,failureType=system_error,additionalProperties={}],estimate=<null>,additionalProperties={}],control=<null>,additionalProperties={}]
2022-12-26 08:20:34 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(replicate):246 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:240) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
	at java.lang.Thread.run(Thread.java:1589) ~[?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Destination process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:124) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.replicate(DefaultReplicationWorker.java:185) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:164) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:84) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$5(TemporalAttemptExecution.java:195) ~[io.airbyte-airbyte-workers-0.40.26.jar:?]
		at java.lang.Thread.run(Thread.java:1589) ~[?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276) ~[io.airbyte-airbyte-commons-worker-0.40.26.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) ~[?:?]
	... 1 more
2022-12-26 08:20:34 [32mINFO[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):503 - Source did not output any state messages
2022-12-26 08:20:34 [33mWARN[m i.a.w.g.DefaultReplicationWorker(prepStateForLaterSaving):511 - State capture: No new state, falling back on input state: io.airbyte.config.State@1711ea03[state={}]
2022-12-26 08:20:34 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):434 - sync summary: {
  "status" : "failed",
  "recordsSynced" : 5,
  "bytesSynced" : 454,
  "startTime" : 1672042752249,
  "endTime" : 1672042834513,
  "totalStats" : {
    "recordsEmitted" : 5,
    "bytesEmitted" : 454,
    "sourceStateMessagesEmitted" : 0,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBeforeSourceStateMessageEmitted" : 0,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "replicationStartTime" : 1672042752249,
    "replicationEndTime" : 1672042834513,
    "sourceReadStartTime" : 1672042752394,
    "sourceReadEndTime" : 1672042773111,
    "destinationWriteStartTime" : 1672042752630,
    "destinationWriteEndTime" : 1672042834511
  },
  "streamStats" : [ {
    "streamName" : "customers",
    "streamNamespace" : "dbo",
    "stats" : {
      "recordsEmitted" : 5,
      "bytesEmitted" : 454
    }
  } ]
}
2022-12-26 08:20:34 [32mINFO[m i.a.w.g.DefaultReplicationWorker(getReplicationOutput):435 - failures: [ {
  "failureOrigin" : "destination",
  "failureType" : "system_error",
  "internalMessage" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.",
  "externalMessage" : "Something went wrong in the connector. See the logs for more details.",
  "metadata" : {
    "attemptNumber" : 2,
    "jobId" : 6,
    "from_trace_message" : true,
    "connector_command" : "write"
  },
  "stacktrace" : "java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)\n\tat org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)\n\tat org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)\n\tat io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)\n\tat io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)\n\tat io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)\n\tat io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)\n\tat io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)\n\tat io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)\n\tat io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)\n\tat io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)\n\tat io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)\nCaused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.\n",
  "timestamp" : 1672042834067
}, {
  "failureOrigin" : "destination",
  "internalMessage" : "io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1",
  "externalMessage" : "Something went wrong within the destination connector",
  "metadata" : {
    "attemptNumber" : 2,
    "jobId" : 6,
    "connector_command" : "write"
  },
  "stacktrace" : "java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)\n\tat java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)\n\tat java.base/java.lang.Thread.run(Thread.java:1589)\nCaused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1\n\tat io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)\n\tat java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)\n\t... 3 more\n",
  "timestamp" : 1672042834511
} ]
2022-12-26 08:20:34 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):163 - Stopping cancellation check scheduling...
2022-12-26 08:20:34 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:20:34 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2022-12-26 08:20:34 [32mINFO[m i.a.c.i.LineGobbler(voidCall):114 - 
2022-12-26 08:20:34 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):205 - sync summary: io.airbyte.config.StandardSyncOutput@52529588[standardSyncSummary=io.airbyte.config.StandardSyncSummary@204fcd6e[status=failed,recordsSynced=5,bytesSynced=454,startTime=1672042752249,endTime=1672042834513,totalStats=io.airbyte.config.SyncStats@6d5ca929[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=0,destinationStateMessagesEmitted=0,recordsCommitted=0,meanSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBeforeSourceStateMessageEmitted=0,maxSecondsBetweenStateMessageEmittedandCommitted=0,meanSecondsBetweenStateMessageEmittedandCommitted=0,replicationStartTime=1672042752249,replicationEndTime=1672042834513,sourceReadStartTime=1672042752394,sourceReadEndTime=1672042773111,destinationWriteStartTime=1672042752630,destinationWriteEndTime=1672042834511,additionalProperties={}],streamStats=[io.airbyte.config.StreamSyncStats@69d90547[streamName=customers,streamNamespace=dbo,stats=io.airbyte.config.SyncStats@2fe13321[recordsEmitted=5,bytesEmitted=454,sourceStateMessagesEmitted=<null>,destinationStateMessagesEmitted=<null>,recordsCommitted=<null>,meanSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBeforeSourceStateMessageEmitted=<null>,maxSecondsBetweenStateMessageEmittedandCommitted=<null>,meanSecondsBetweenStateMessageEmittedandCommitted=<null>,replicationStartTime=<null>,replicationEndTime=<null>,sourceReadStartTime=<null>,sourceReadEndTime=<null>,destinationWriteStartTime=<null>,destinationWriteEndTime=<null>,additionalProperties={}]]]],normalizationSummary=<null>,webhookOperationSummary=<null>,state=io.airbyte.config.State@1711ea03[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@719baf0e[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@790655f5[stream=io.airbyte.protocol.models.AirbyteStream@58d484af[name=customers,jsonSchema={"type":"object","properties":{"id":{"type":"number","airbyte_type":"integer"},"email":{"type":"string"},"last_name":{"type":"string"},"first_name":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=dbo,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@7e8adcaf[failureOrigin=destination,failureType=system_error,internalMessage=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.,externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@52c5ffaf[additionalProperties={attemptNumber=2, jobId=6, from_trace_message=true, connector_command=write}],stacktrace=java.lang.RuntimeException: Cannot send message to Kafka. Error: Topic Topico_Customers not present in metadata after 60000 ms.
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.lambda$sendRecord$2(KafkaRecordConsumer.java:94)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:982)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:885)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.sendRecord(KafkaRecordConsumer.java:91)
	at io.airbyte.integrations.destination.kafka.KafkaRecordConsumer.acceptTracked(KafkaRecordConsumer.java:75)
	at io.airbyte.integrations.base.FailureTrackingAirbyteMessageConsumer.accept(FailureTrackingAirbyteMessageConsumer.java:47)
	at io.airbyte.integrations.base.IntegrationRunner.consumeMessage(IntegrationRunner.java:259)
	at io.airbyte.integrations.base.IntegrationRunner.consumeWriteStream(IntegrationRunner.java:172)
	at io.airbyte.integrations.base.IntegrationRunner.lambda$runConsumer$2(IntegrationRunner.java:178)
	at io.airbyte.integrations.base.IntegrationRunner.watchForOrphanThreads(IntegrationRunner.java:207)
	at io.airbyte.integrations.base.IntegrationRunner.runConsumer(IntegrationRunner.java:177)
	at io.airbyte.integrations.base.IntegrationRunner.runInternal(IntegrationRunner.java:146)
	at io.airbyte.integrations.base.IntegrationRunner.run(IntegrationRunner.java:97)
	at io.airbyte.integrations.destination.kafka.KafkaDestination.main(KafkaDestination.java:85)
Caused by: org.apache.kafka.common.errors.TimeoutException: Topic Topico_Customers not present in metadata after 60000 ms.
,retryable=<null>,timestamp=1672042834067], io.airbyte.config.FailureReason@19a7a1ff[failureOrigin=destination,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1,externalMessage=Something went wrong within the destination connector,metadata=io.airbyte.config.Metadata@652abf98[additionalProperties={attemptNumber=2, jobId=6, connector_command=write}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1589)
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$DestinationException: Destination process exited with non-zero exit code 1
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$readFromDstRunnable$4(DefaultReplicationWorker.java:276)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
,retryable=<null>,timestamp=1672042834511]]]
2022-12-26 08:20:34 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):210 - Sync summary length: 5972
2022-12-26 08:20:34 [32mINFO[m i.a.c.t.TemporalUtils(withBackgroundHeartbeat):283 - Stopping temporal heartbeating...
2022-12-26 08:20:34 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to get state
2022-12-26 08:20:34 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):64 - Using default value for environment variable NEED_STATE_VALIDATION: 'true'
2022-12-26 08:20:34 [32mINFO[m i.a.a.c.AirbyteApiClient(retryWithJitter):172 - Attempt 0 to create or update state