THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
{ "record": { "topic": "connect-test", "timestamp": 1526518349968, "timestamp_type": "CREATE_TIME", "offset": 918264, "partition": 7, "key": { "schema": "SCHEMA{STRUCT}", "object": "{\"id\":1012}" }, "value": { "schema": "SCHEMA{BYTES}", "object": "eyJhOiAxMH0=" } }, "index": 1, "exception": "org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error: \norg.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error: \n\tat org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:334)\n\t...", "attempt": 10, "task_id": "my-connector-1", "time_of_error": 1526518715403, "stages": [ { "type": "KEY_CONVERTER", "config": { "converter.type": "value", "schemas.enable": "false" }, "class": "org.apache.kafka.connect.json.JsonConverter" }, { "type": "VALUE_CONVERTER", "config": { "converter.type": "value", "schemas.enable": "false" }, "class": "org.apache.kafka.connect.json.JsonConverter" }, { "type": "TRANSFORMATION", "config": { "whitelist": "a,b" }, "class": "org.apache.kafka.connect.transforms.ReplaceField$Value" }, { "type": "TASK_PUT", "config": { "name": "local-file-sink", "connector.class": "FileStreamSink", "tasks.max": 1, "file": "test.sink.txt", "topics": "connect-test" }, "class": "org.apache.kafka.connect.json.JsonConverter" } ] } |
...
Compatibility, Deprecation, and Migration Plan
The current behavior in Connect is to kill the task on the first error in any stage. As mentioned above, this will remain the default behavior if connector configurations are not changed.
...