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": "f1a,f2b" }, "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" } ] } |
...