2022-05-12 10:53:45 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-12 10:53:45 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/355/0/logs.log
2022-05-12 10:53:45 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.65-alpha
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(run):104 - start sync worker. job id: 355 attempt id: 0
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(run):116 - configured sync modes: {PUBLIC.ALLERGIES=full_refresh - overwrite, PUBLIC._AIRBYTE_RAW_ALLERGIES=full_refresh - overwrite}
2022-05-12 10:53:45 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-05-12 10:53:45 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-kafka:0.1.6 exists...
2022-05-12 10:53:45 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-kafka:0.1.6 was found locally.
2022-05-12 10:53:45 INFO i.a.w.p.DockerProcessFactory(create):106 - Creating docker job ID: 355
2022-05-12 10:53:45 INFO i.a.w.p.DockerProcessFactory(create):158 - Preparing command: docker run --rm --init -i -w /data/355/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e WORKER_CONNECTOR_IMAGE=airbyte/destination-kafka:0.1.6 -e WORKER_JOB_ATTEMPT=0 -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e AIRBYTE_VERSION=0.35.65-alpha -e WORKER_JOB_ID=355 airbyte/destination-kafka:0.1.6 write --config destination_config.json --catalog destination_catalog.json
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(run):158 - Waiting for source and destination threads to complete.
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):279 - Replication thread started.
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):339 - Destination output thread started.
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):305 - Total records read: 1 (0 bytes)
2022-05-12 10:53:45 INFO i.a.w.DefaultReplicationWorker(run):163 - One of source or destination thread complete. Waiting on the other.
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.d.k.KafkaDestination(main):84 - Starting destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.b.IntegrationRunner(runInternal):105 - Running integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.b.IntegrationRunner(runInternal):106 - Command: WRITE
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.b.IntegrationRunner(runInternal):107 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 WARN 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-05-12 10:53:47 destination > 2022-05-12 10:53:47 WARN 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-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.d.k.KafkaDestinationConfig(propertiesByProtocol):81 - Kafka protocol config: {"security_protocol":"PLAINTEXT"}
2022-05-12 10:53:47 destination > 2022-05-12 10:53:47 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):63 - Airbyte message consumer: succeeded.
2022-05-12 10:53:48 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):349 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@5cb25c0d[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@5275a9eb[data={},additionalProperties={}],additionalProperties={}]
2022-05-12 10:53:48 destination > 2022-05-12 10:53:48 INFO i.a.i.b.IntegrationRunner(runInternal):153 - Completed integration: io.airbyte.integrations.destination.kafka.KafkaDestination
2022-05-12 10:53:48 destination > 2022-05-12 10:53:48 INFO i.a.i.d.k.KafkaDestination(main):86 - Completed destination: class io.airbyte.integrations.destination.kafka.KafkaDestination
2022-05-12 10:53:48 INFO i.a.w.DefaultReplicationWorker(run):165 - Source and destination threads complete.
2022-05-12 10:53:48 INFO i.a.w.DefaultReplicationWorker(run):228 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6a3c0821[status=completed,recordsSynced=0,bytesSynced=0,startTime=1652352825888,endTime=1652352828371,totalStats=io.airbyte.config.SyncStats@70b7eb3f[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]]
2022-05-12 10:53:48 INFO i.a.w.DefaultReplicationWorker(run):248 - Source output at least one state message
2022-05-12 10:53:48 INFO i.a.w.DefaultReplicationWorker(run):254 - State capture: Updated state to: Optional[io.airbyte.config.State@278940e1[state={}]]
2022-05-12 10:53:48 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-05-12 10:53:48 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):147 - sync summary: io.airbyte.config.StandardSyncOutput@3d980bea[standardSyncSummary=io.airbyte.config.StandardSyncSummary@366a082a[status=completed,recordsSynced=0,bytesSynced=0,startTime=1652352825888,endTime=1652352828371,totalStats=io.airbyte.config.SyncStats@70b7eb3f[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=1,recordsCommitted=0],streamStats=[]],state=io.airbyte.config.State@278940e1[state={}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@5d6ee882[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@44ecc6ff[stream=io.airbyte.protocol.models.AirbyteStream@39d652d3[name=_AIRBYTE_RAW_ALLERGIES,jsonSchema={"type":"object","properties":{"_AIRBYTE_DATA":{"type":"string"},"_AIRBYTE_AB_ID":{"type":"string"},"_AIRBYTE_EMITTED_AT":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[_AIRBYTE_AB_ID]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[[_AIRBYTE_AB_ID]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5f9b369b[stream=io.airbyte.protocol.models.AirbyteStream@759bff12[name=ALLERGIES,jsonSchema={"type":"object","properties":{"CODE":{"type":"number"},"STOP":{"type":"number"},"TYPE":{"type":"string"},"START":{"type":"string"},"SYSTEM":{"type":"string"},"PATIENT":{"type":"string"},"CATEGORY":{"type":"string"},"ENCOUNTER":{"type":"string"},"REACTION1":{"type":"number"},"REACTION2":{"type":"number"},"SEVERITY1":{"type":"string"},"SEVERITY2":{"type":"string"},"DESCRIPTION":{"type":"string"},"DESCRIPTION1":{"type":"string"},"DESCRIPTION2":{"type":"string"},"_AIRBYTE_AB_ID":{"type":"string"},"_AIRBYTE_EMITTED_AT":{"type":"string"},"_AIRBYTE_NORMALIZED_AT":{"type":"string"},"_AIRBYTE_ALLERGIES_HASHID":{"type":"string"}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=overwrite,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-05-12 10:53:48 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):235 - Stopping temporal heartbeating...
2022-05-12 10:53:48 INFO i.a.c.p.ConfigRepository(updateConnectionState):731 - Updating connection 52da8c85-cb88-4d6a-85b9-481a60b3854f state: io.airbyte.config.State@5a004e65[state={}]