2018/12/14 06:08:10 Starting coyote-tester
2018/12/14 06:08:10 Starting processing group: [ Brokers ]
2018/12/14 06:08:27 Success, command 'bash -c 'for ((i=0;i<60;i++)); do sleep 2; echo dump | nc localhost 2181 | grep brokers && { sleep 5; break; }; done'', test 'Wait for broker to get up'. Stdout: "\t/brokers/ids/0\n"
2018/12/14 06:08:29 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_basic_1544767707819 --partitions 1 --replication-factor 1
             --create --config retention.ms=60000 --config retention.bytes=52428800
', test 'Create Topic (basic kafka)'. Stdout: "WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.\nCreated topic \"coyote_basic_1544767707819\".\n"
2018/12/14 06:08:31 Success, command 'kafka-topics --zookeeper localhost:2181 --list', test 'List Topics (basic kafka)'. Stdout: "__consumer_offsets\n_schemas\ncoyote_basic_1544767707819\n"
2018/12/14 06:08:42 Success, command 'kafka-producer-perf-test --topic coyote_basic_1544767707819 --throughput 100000 --record-size 1000 --num-records 500000
                         --producer-props bootstrap.servers="localhost:9092"
', test 'Performance Test (basic kafka)'. Stdout: "194481 records sent, 38896.2 records/sec (37.09 MB/sec), 745.5 ms avg latency, 1095.0 max latency.\n301744 records sent, 60348.8 records/sec (57.55 MB/sec), 543.5 ms avg latency, 719.0 max latency.\n500000 records sent, 49672.163719 records/sec (47.37 MB/sec), 621.81 ms avg latency, 1095.00 ms max latency, 549 ms 50th, 954 ms 95th, 1037 ms 99th, 1084 ms 99.9th.\n"
2018/12/14 06:08:42 Starting processing group: [ REST Proxy ]
2018/12/14 06:08:46 Success, command 'bash -c 'for ((i=0;i<90;i++)); do sleep 2; curl "http://localhost:8082" | grep "{}" && { sleep 2; break; }; done'', test 'Wait for rest proxy to get up'. Stdout: "{}\n"
2018/12/14 06:08:46 Success, command 'curl -vs --stderr - "http://localhost:8082/topics"', test 'List Topics (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /topics HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:46 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 154\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [154 bytes data]\n[\"_schemas\",\"backblaze_smart\",\"coyote_basic_1544767707819\",\"nyc_yellow_taxi_trip_data\",\"reddit_posts\",\"sea_vessel_position_reports\",\"telecom_italia_data\"]* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:46 Success, command 'curl -vs --stderr - "http://localhost:8082/topics/coyote_basic_1544767707819"', test 'Topic Information (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /topics/coyote_basic_1544767707819 HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:46 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 932\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [932 bytes data]\n{\"name\":\"coyote_basic_1544767707819\",\"configs\":{\"file.delete.delay.ms\":\"60000\",\"segment.ms\":\"604800000\",\"min.compaction.lag.ms\":\"0\",\"retention.bytes\":\"52428800\",\"segment.index.bytes\":\"10485760\",\"cleanup.policy\":\"delete\",\"follower.replication.throttled.replicas\":\"\",\"message.timestamp.difference.max.ms\":\"9223372036854775807\",\"segment.jitter.ms\":\"0\",\"preallocate\":\"false\",\"segment.bytes\":\"104857600\",\"message.timestamp.type\":\"CreateTime\",\"message.format.version\":\"1.1-IV0\",\"max.message.bytes\":\"1000012\",\"unclean.leader.election.enable\":\"false\",\"retention.ms\":\"60000\",\"flush.ms\":\"9223372036854775807\",\"delete.retention.ms\":\"86400000\",\"leader.replication.throttled.replicas\":\"\",\"min.insync.replicas\":\"1\",\"flush.messages\":\"9223372036854775807\",\"compression.type\":\"producer\",\"min.cleanable.dirty.ratio\":\"0.5\",\"index.interval.bytes\":\"4096\"},\"partitions\":[{\"partition\":0,\"leader\":0,\"replicas\":[{\"broker\":0,\"leader\":true,\"in_sync\":true}]}]}* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:46 Success, command 'curl -vs --stderr - "http://localhost:8082/topics/coyote_basic_1544767707819/partitions"', test 'Topic Partitions (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /topics/coyote_basic_1544767707819/partitions HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:46 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 83\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [83 bytes data]\n[{\"partition\":0,\"leader\":0,\"replicas\":[{\"broker\":0,\"leader\":true,\"in_sync\":true}]}]* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:48 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_basic_1544767707819 --delete', test 'Delete Topic (basic kafka)'. Stdout: "Topic coyote_basic_1544767707819 is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:08:48 Success, command 'curl -vs --stderr - -XPOST
     -H "Content-Type: application/vnd.kafka.avro.v1+json"
     --data '{"value_schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}]}",
              "records": [{"value": {"name": "testUser"}}]}'
     "http://localhost:8082/topics/coyote-test-avro"
', test 'Produce Avro Message (rest proxy, schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /topics/coyote-test-avro HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.avro.v1+json\r\n> Content-Length: 180\r\n> \r\n} [180 bytes data]\n* upload completely sent off: 180 out of 180 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:48 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 112\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [112 bytes data]\n{\"offsets\":[{\"partition\":0,\"offset\":0,\"error_code\":null,\"error\":null}],\"key_schema_id\":null,\"value_schema_id\":1}* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:49 Success, command 'curl -vs --stderr - -XPOST -H "Content-Type: application/vnd.kafka.v1+json"
     --data '{"name": "a-consumer", "format": "avro", "auto.offset.reset": "smallest"}'
     "http://localhost:8082/consumers/coyote-avro"
', test 'Create Consumer for Avro data (rest proxy, schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /consumers/coyote-avro HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.v1+json\r\n> Content-Length: 73\r\n> \r\n} [73 bytes data]\n* upload completely sent off: 73 out of 73 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:48 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 106\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [106 bytes data]\n{\"instance_id\":\"a-consumer\",\"base_uri\":\"http://localhost:8082/consumers/coyote-avro/instances/a-consumer\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:54 Success, command 'sleep 5', test ''. Stdout: ""
2018/12/14 06:08:54 Success, command 'curl -vs --stderr - -XGET -H "Accept: application/vnd.kafka.avro.v1+json"
     "http://localhost:8082/consumers/coyote-avro/instances/a-consumer/topics/coyote-test-avro?max_bytes=30"
', test 'Consume Avro Message (rest proxy, schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /consumers/coyote-avro/instances/a-consumer/topics/coyote-test-avro?max_bytes=30 HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: application/vnd.kafka.avro.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:08:54 GMT\r\n< Content-Type: application/vnd.kafka.avro.v1+json\r\n< Content-Length: 94\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [94 bytes data]\n[{\"topic\":\"coyote-test-avro\",\"key\":null,\"value\":{\"name\":\"testUser\"},\"partition\":0,\"offset\":0}]* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:54 Success, command 'curl -vs --stderr - -X DELETE "http://localhost:8082/consumers/coyote-avro/instances/a-consumer"', test 'Delete Avro Consumer (rest proxy, schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> DELETE /consumers/coyote-avro/instances/a-consumer HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Fri, 14 Dec 2018 06:08:54 GMT\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2018/12/14 06:08:56 Success, command 'kafka-consumer-groups  --zookeeper localhost:2181 --delete --group coyote-avro', test 'Delete Consumer Group Info'. Stdout: "Deleted all consumer group information for group 'coyote-avro' in zookeeper.\n"
2018/12/14 06:09:01 Success, command 'sleep 5', test ''. Stdout: ""
2018/12/14 06:09:03 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote-test-avro --delete', test ''. Stdout: "Topic coyote-test-avro is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:09:03 Success, command 'curl -vs --stderr - -XPOST -H "Content-Type: application/vnd.kafka.json.v1+json"
      --data '{"records":[{"value":{"foo":"bar"}}]}' "http://localhost:8082/topics/coyote-test-json"
', test 'Produce JSON Message (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /topics/coyote-test-json HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.json.v1+json\r\n> Content-Length: 37\r\n> \r\n} [37 bytes data]\n* upload completely sent off: 37 out of 37 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:03 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 115\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [115 bytes data]\n{\"offsets\":[{\"partition\":0,\"offset\":0,\"error_code\":null,\"error\":null}],\"key_schema_id\":null,\"value_schema_id\":null}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:03 Success, command 'curl -vs --stderr - -XPOST -H "Content-Type: application/vnd.kafka.v1+json"
      --data '{"name": "a-consumer", "format": "json", "auto.offset.reset": "smallest"}'
      "http://localhost:8082/consumers/coyote-json"
', test 'Create Consumer for JSON data (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /consumers/coyote-json HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.v1+json\r\n> Content-Length: 73\r\n> \r\n} [73 bytes data]\n* upload completely sent off: 73 out of 73 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:03 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 106\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [106 bytes data]\n{\"instance_id\":\"a-consumer\",\"base_uri\":\"http://localhost:8082/consumers/coyote-json/instances/a-consumer\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:05 Success, command 'sleep 2', test ''. Stdout: ""
2018/12/14 06:09:05 Success, command 'curl -vs --stderr - -XGET -H "Accept: application/vnd.kafka.json.v1+json"
      "http://localhost:8082/consumers/coyote-json/instances/a-consumer/topics/coyote-test-json?max_bytes=15"
', test 'Consume JSON Message (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /consumers/coyote-json/instances/a-consumer/topics/coyote-test-json?max_bytes=15 HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: application/vnd.kafka.json.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:05 GMT\r\n< Content-Type: application/vnd.kafka.json.v1+json\r\n< Content-Length: 88\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [88 bytes data]\n[{\"topic\":\"coyote-test-json\",\"key\":null,\"value\":{\"foo\":\"bar\"},\"partition\":0,\"offset\":0}]* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:05 Success, command 'curl -vs --stderr - -X DELETE "http://localhost:8082/consumers/coyote-json/instances/a-consumer"', test 'Delete JSON Consumer (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> DELETE /consumers/coyote-json/instances/a-consumer HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Fri, 14 Dec 2018 06:09:05 GMT\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:06 Success, command 'kafka-consumer-groups  --zookeeper localhost:2181 --delete --group coyote-json', test 'Delete Consumer Group Info'. Stdout: "Deleted all consumer group information for group 'coyote-json' in zookeeper.\n"
2018/12/14 06:09:08 Success, command 'sleep 2', test ''. Stdout: ""
2018/12/14 06:09:10 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote-test-json --delete', test ''. Stdout: "Topic coyote-test-json is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:09:10 Success, command 'curl -vs --stderr - -XPOST -H "Content-Type: application/vnd.kafka.binary.v1+json"
    --data '{"records":[{"value":"S2Fma2E="}]}' "http://localhost:8082/topics/coyote-test-binary"
', test 'Produce Binary Message (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /topics/coyote-test-binary HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.binary.v1+json\r\n> Content-Length: 34\r\n> \r\n} [34 bytes data]\n* upload completely sent off: 34 out of 34 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:10 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 115\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [115 bytes data]\n{\"offsets\":[{\"partition\":0,\"offset\":0,\"error_code\":null,\"error\":null}],\"key_schema_id\":null,\"value_schema_id\":null}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:10 Success, command 'curl -vs --stderr - -XPOST -H "Content-Type: application/vnd.kafka.v1+json"
      --data '{"name": "a-consumer", "format": "binary", "auto.offset.reset": "smallest"}'
      "http://localhost:8082/consumers/coyote-binary"
', test 'Create Consumer for Binary data (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> POST /consumers/coyote-binary HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.kafka.v1+json\r\n> Content-Length: 75\r\n> \r\n} [75 bytes data]\n* upload completely sent off: 75 out of 75 bytes\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:10 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 108\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [108 bytes data]\n{\"instance_id\":\"a-consumer\",\"base_uri\":\"http://localhost:8082/consumers/coyote-binary/instances/a-consumer\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:12 Success, command 'sleep 2', test ''. Stdout: ""
2018/12/14 06:09:12 Success, command 'curl -vs --stderr - -XGET -H "Accept: application/vnd.kafka.binary.v1+json"
      "http://localhost:8082/consumers/coyote-binary/instances/a-consumer/topics/coyote-test-binary?max_bytes=10"
', test 'Consume Binary Message (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /consumers/coyote-binary/instances/a-consumer/topics/coyote-test-binary?max_bytes=10 HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: application/vnd.kafka.binary.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:12 GMT\r\n< Content-Type: application/vnd.kafka.binary.v1+json\r\n< Content-Length: 87\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [87 bytes data]\n[{\"topic\":\"coyote-test-binary\",\"key\":null,\"value\":\"S2Fma2E=\",\"partition\":0,\"offset\":0}]* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:12 Success, command 'curl -vs --stderr - -XDELETE "http://localhost:8082/consumers/coyote-binary/instances/a-consumer"', test 'Delete Binary Consumer (rest proxy)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> DELETE /consumers/coyote-binary/instances/a-consumer HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Fri, 14 Dec 2018 06:09:12 GMT\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:14 Success, command 'kafka-consumer-groups  --zookeeper localhost:2181 --delete --group coyote-binary', test 'Delete Consumer Group Info'. Stdout: "Deleted all consumer group information for group 'coyote-binary' in zookeeper.\n"
2018/12/14 06:09:19 Success, command 'sleep 5', test ''. Stdout: ""
2018/12/14 06:09:20 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote-test-binary --delete', test ''. Stdout: "Topic coyote-test-binary is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:09:20 Starting processing group: [ Schema Registry ]
2018/12/14 06:09:20 Success, command 'curl  -vs --stderr - -XPOST -i -H "Content-Type: application/vnd.schemaregistry.v1+json"
     --data '{"schema": "{\"type\": \"string\"}"}'
     "http://localhost:8081/subjects/coyote_basic/versions"
', test 'Register a new Schema version (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> POST /subjects/coyote_basic/versions HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.schemaregistry.v1+json\r\n> Content-Length: 36\r\n> \r\n} [36 bytes data]\n* upload completely sent off: 36 out of 36 bytes\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 8\r\nContent-Length: 8\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [8 bytes data]\n{\"id\":8}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/subjects"', test 'List subjects (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> GET /subjects HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 205\r\nContent-Length: 205\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [205 bytes data]\n[\"coyote-test-avro-value\",\"reddit_posts-key\",\"telecom_italia_data-key\",\"reddit_posts-value\",\"telecom_italia_data-value\",\"coyote_basic\",\"sea_vessel_position_reports-key\",\"sea_vessel_position_reports-value\"]* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/subjects/coyote_basic/versions"', test 'List Schema versions (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> GET /subjects/coyote_basic/versions HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 3\r\nContent-Length: 3\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [3 bytes data]\n[1]* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/subjects/coyote_basic/versions/1"', test 'Fetch Schema by name and version (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> GET /subjects/coyote_basic/versions/1 HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 67\r\nContent-Length: 67\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [67 bytes data]\n{\"subject\":\"coyote_basic\",\"version\":1,\"id\":8,\"schema\":\"\\\"string\\\"\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XPOST -i -H "Content-Type: application/vnd.schemaregistry.v1+json"
     --data '{"schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}]}"}'
     "http://localhost:8081/subjects/coyote_test_02/versions"
', test 'Register Complex Schema (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> POST /subjects/coyote_test_02/versions HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.schemaregistry.v1+json\r\n> Content-Length: 114\r\n> \r\n} [114 bytes data]\n* upload completely sent off: 114 out of 114 bytes\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 8\r\nContent-Length: 8\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [8 bytes data]\n{\"id\":1}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XPOST -i -H "Content-Type: application/vnd.schemaregistry.v1+json"
     --data '{"schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}, {\"name\": \"address\", \"type\": \"string\"}]}"}'
     "http://localhost:8081/compatibility/subjects/coyote_test_02/versions/latest"
', test 'Test Schema Compatibility (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> POST /compatibility/subjects/coyote_test_02/versions/latest HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/vnd.schemaregistry.v1+json\r\n> Content-Length: 161\r\n> \r\n} [161 bytes data]\n* upload completely sent off: 161 out of 161 bytes\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 23\r\nContent-Length: 23\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [23 bytes data]\n{\"is_compatible\":false}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/config"', test 'Get Schema Registry Configuration (schema registry)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8081 (#0)\n> GET /config HTTP/1.1\r\n> Host: localhost:8081\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:20 GMT\r\nDate: Fri, 14 Dec 2018 06:09:20 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 33\r\nContent-Length: 33\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [33 bytes data]\n{\"compatibilityLevel\":\"BACKWARD\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:20 Starting processing group: [ Connect ]
2018/12/14 06:09:30 Success, command 'bash -c 'for ((i=0;i<60;i++)); do sleep 5; curl "http://localhost:8083/connectors" && { sleep 5; break; }; done'', test 'Wait for connect to get up'. Stdout: "[\"logs-broker\"]"
2018/12/14 06:09:30 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8083/connectors"', test 'Get list of Connectors (connect distributed)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> GET /connectors HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:30 GMT\r\nDate: Fri, 14 Dec 2018 06:09:30 GMT\r\n< Content-Type: application/json\r\nContent-Type: application/json\r\n< Content-Length: 15\r\nContent-Length: 15\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [15 bytes data]\n[\"logs-broker\"]* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:31 Success, command 'curl -vs --stderr - -X POST -H "Content-Type: application/json"
     --data '{ "name": "coyote_test_console_source-1544767770845",
       "config": {"connector.class":"org.apache.kafka.connect.file.FileStreamSourceConnector","tasks.max":"1","topic":"coyote_cd-1544767770845","file":"/etc/fstab"}}'
     "http://localhost:8083/connectors"
', test 'Create a Console Connector (connect distributed)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> POST /connectors HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> Content-Type: application/json\r\n> Content-Length: 219\r\n> \r\n} [219 bytes data]\n* upload completely sent off: 219 out of 219 bytes\n< HTTP/1.1 201 Created\r\n< Date: Fri, 14 Dec 2018 06:09:30 GMT\r\n< Location: http://localhost:8083/connectors/coyote_test_console_source-1544767770845\r\n< Content-Type: application/json\r\n< Content-Length: 281\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n{ [281 bytes data]\n{\"name\":\"coyote_test_console_source-1544767770845\",\"config\":{\"connector.class\":\"org.apache.kafka.connect.file.FileStreamSourceConnector\",\"tasks.max\":\"1\",\"topic\":\"coyote_cd-1544767770845\",\"file\":\"/etc/fstab\",\"name\":\"coyote_test_console_source-1544767770845\"},\"tasks\":[],\"type\":null}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:41 Success, command 'sleep 10', test 'Sleep a bit to let the connector spawn and work'. Stdout: ""
2018/12/14 06:09:41 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8083/connectors/coyote_test_console_source-1544767770845"', test 'Get Connector s Configuration (connect distributed)'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> GET /connectors/coyote_test_console_source-1544767770845 HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Fri, 14 Dec 2018 06:09:41 GMT\r\nDate: Fri, 14 Dec 2018 06:09:41 GMT\r\n< Content-Type: application/json\r\nContent-Type: application/json\r\n< Content-Length: 350\r\nContent-Length: 350\r\n< Server: Jetty(9.2.24.v20180105)\r\nServer: Jetty(9.2.24.v20180105)\r\n\r\n< \r\n{ [350 bytes data]\n{\"name\":\"coyote_test_console_source-1544767770845\",\"config\":{\"connector.class\":\"org.apache.kafka.connect.file.FileStreamSourceConnector\",\"file\":\"/etc/fstab\",\"tasks.max\":\"1\",\"name\":\"coyote_test_console_source-1544767770845\",\"topic\":\"coyote_cd-1544767770845\"},\"tasks\":[{\"connector\":\"coyote_test_console_source-1544767770845\",\"task\":0}],\"type\":\"source\"}* Connection #0 to host localhost left intact\n"
2018/12/14 06:09:48 Success, command 'timeout 10
kafka-console-consumer --new-consumer
                       --bootstrap-server localhost:9092
                       --topic coyote_cd-1544767770845
                       --from-beginning
                       --timeout-ms 5000
', test 'Run Console Consumer to fix Kafka's transient state (basic kafka)'. Stdout: "\x00\x00\x00\x00\bZ/dev/cdrom\t/media/cdrom\tiso9660\tnoauto,ro 0 0\n\x00\x00\x00\x00\bT/dev/usbdisk\t/media/usb\tvfat\tnoauto,ro 0 0\n"
2018/12/14 06:09:56 Success, command 'timeout 10
kafka-console-consumer --new-consumer
                       --bootstrap-server localhost:9092
                       --topic coyote_cd-1544767770845
                       --from-beginning
                       --timeout-ms 5000
', test 'Run Console Consumer (basic kafka)'. Stdout: "\x00\x00\x00\x00\bZ/dev/cdrom\t/media/cdrom\tiso9660\tnoauto,ro 0 0\n\x00\x00\x00\x00\bT/dev/usbdisk\t/media/usb\tvfat\tnoauto,ro 0 0\n"
2018/12/14 06:09:56 Success, command 'curl -vs --stderr - -XDELETE "http://localhost:8083/connectors/coyote_test_console_source-1544767770845"', test 'Delete connector'. Stdout: "*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> DELETE /connectors/coyote_test_console_source-1544767770845 HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.61.1\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Fri, 14 Dec 2018 06:09:56 GMT\r\n< Server: Jetty(9.2.24.v20180105)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2018/12/14 06:10:01 Success, command 'sleep 5', test ''. Stdout: ""
2018/12/14 06:10:03 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_cd-1544767770845 --delete', test 'Delete Connect Distributes Test Topic (basic kafka)'. Stdout: "Topic coyote_cd-1544767770845 is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:10:03 Success, command 'rm -rf coyote_test.sqlite coyote_sqlite_connector.properties coyote_connect_standalone.properties coyote_connect.offset', test ''. Stdout: ""
2018/12/14 06:10:03 Success, command 'sqlite3 coyote_test.sqlite', test 'Create and Init SQLite database'. Stdout: ""
2018/12/14 06:10:03 Success, command 'tee coyote_sqlite_connector.properties', test 'Create coyote_sqlite_connector.properties'. Stdout: "name=coyote-ca-1544767803315\nconnector.class=io.confluent.connect.jdbc.JdbcSourceConnector\ntasks.max=1\nconnection.url=jdbc:sqlite:coyote_test.sqlite\nmode=incrementing\nincrementing.column.name=id\ntopic.prefix=coyote-ca-\n"
2018/12/14 06:10:03 Success, command 'tee coyote_connect_standalone.properties', test 'Create coyote_connect_standalone.properties'. Stdout: "bootstrap.servers=localhost:9092\nkey.converter=io.confluent.connect.avro.AvroConverter\nkey.converter.schema.registry.url=http://localhost:8081\nvalue.converter=io.confluent.connect.avro.AvroConverter\nvalue.converter.schema.registry.url=http://localhost:8081\ninternal.key.converter=org.apache.kafka.connect.json.JsonConverter\ninternal.value.converter=org.apache.kafka.connect.json.JsonConverter\ninternal.key.converter.schemas.enable=false\ninternal.value.converter.schemas.enable=false\noffset.storage.file.filename=coyote_connect.offset\noffset.flush.interval.ms=5000\nzookeeper=localhost:2181\nrest.port=38783\nport=38783\nplugin.path=/opt/landoop/connectors/third-party\n"
2018/12/14 06:10:51 Success, command 'timeout -k 5 45 connect-standalone coyote_connect_standalone.properties coyote_sqlite_connector.properties', test 'Read SQLite into Topic (connect standalone)'. Stdout: "[2018-12-14 06:10:04,475] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:67)\n[2018-12-14 06:10:04,488] INFO WorkerInfo values: \n\tjvm.args = -Xmx640M, -Xms128M, -XX:+UseG1GC, -XX:MaxGCPauseMillis=20, -XX:InitiatingHeapOccupancyPercent=35, -XX:+ExplicitGCInvokesConcurrent, -Djava.awt.headless=true, -Dcom.sun.management.jmxremote, -Dcom.sun.management.jmxremote.authenticate=false, -Dcom.sun.management.jmxremote.ssl=false, -Dkafka.logs.dir=/opt/landoop/kafka/logs, -Dlog4j.configuration=file:/opt/landoop/kafka/etc/kafka/connect-log4j.properties\n\tjvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_181, 25.181-b13\n\tjvm.classpath = /opt/landoop/kafka/share/java/kafka/activation-1.1.1.jar:/opt/landoop/kafka/share/java/kafka/aopalliance-repackaged-2.5.0-b32.jar:/opt/landoop/kafka/share/java/kafka/argparse4j-0.7.0.jar:/opt/landoop/kafka/share/java/kafka/commons-lang3-3.5.jar:/opt/landoop/kafka/share/java/kafka/connect-api-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-file-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-json-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-runtime-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-transforms-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/guava-20.0.jar:/opt/landoop/kafka/share/java/kafka/hk2-api-2.5.0-b32.jar:/opt/landoop/kafka/share/java/kafka/hk2-locator-2.5.0-b32.jar:/opt/landoop/kafka/share/java/kafka/hk2-utils-2.5.0-b32.jar:/opt/landoop/kafka/share/java/kafka/jackson-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/jackson-core-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/jackson-databind-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-base-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-json-provider-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-jaxb-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/kafka/javassist-3.20.0-GA.jar:/opt/landoop/kafka/share/java/kafka/javassist-3.21.0-GA.jar:/opt/landoop/kafka/share/java/kafka/javax.annotation-api-1.2.jar:/opt/landoop/kafka/share/java/kafka/javax.inject-1.jar:/opt/landoop/kafka/share/java/kafka/javax.inject-2.5.0-b32.jar:/opt/landoop/kafka/share/java/kafka/javax.servlet-api-3.1.0.jar:/opt/landoop/kafka/share/java/kafka/javax.ws.rs-api-2.0.1.jar:/opt/landoop/kafka/share/java/kafka/jaxb-api-2.3.0.jar:/opt/landoop/kafka/share/java/kafka/jersey-client-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-common-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-core-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-guava-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-media-jaxb-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jersey-server-2.25.1.jar:/opt/landoop/kafka/share/java/kafka/jetty-client-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-continuation-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-http-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-io-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-security-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-server-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlet-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlets-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jetty-util-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/kafka/jopt-simple-5.0.4.jar:/opt/landoop/kafka/share/java/kafka/kafka-clients-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-custom-principal-builder-1.0-SNAPSHOT.jar:/opt/landoop/kafka/share/java/kafka/kafka-log4j-appender-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-examples-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-test-utils-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-tools-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.11-1.1.1-L0-sources.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.11-1.1.1-L0-test-sources.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.11-1.1.1-L0.jar:/opt/landoop/kafka/share/java/kafka/log4j-1.2.17.jar:/opt/landoop/kafka/share/java/kafka/lz4-java-1.4.1.jar:/opt/landoop/kafka/share/java/kafka/maven-artifact-3.5.3.jar:/opt/landoop/kafka/share/java/kafka/metrics-core-2.2.0.jar:/opt/landoop/kafka/share/java/kafka/osgi-resource-locator-1.0.1.jar:/opt/landoop/kafka/share/java/kafka/plexus-utils-3.1.0.jar:/opt/landoop/kafka/share/java/kafka/reflections-0.9.11.jar:/opt/landoop/kafka/share/java/kafka/rocksdbjni-5.7.3.jar:/opt/landoop/kafka/share/java/kafka/scala-library-2.11.12.jar:/opt/landoop/kafka/share/java/kafka/scala-logging_2.11-3.8.0.jar:/opt/landoop/kafka/share/java/kafka/scala-reflect-2.11.12.jar:/opt/landoop/kafka/share/java/kafka/slf4j-api-1.7.25.jar:/opt/landoop/kafka/share/java/kafka/slf4j-log4j12-1.7.25.jar:/opt/landoop/kafka/share/java/kafka/snappy-java-1.1.7.1.jar:/opt/landoop/kafka/share/java/kafka/validation-api-1.1.0.Final.jar:/opt/landoop/kafka/share/java/kafka/zkclient-0.10.jar:/opt/landoop/kafka/share/java/kafka/zookeeper-3.4.10.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/avro-1.8.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/commons-compress-1.8.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-core-2.9.6.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-core-asl-1.9.13.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-databind-2.9.6.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/jackson-mapper-asl-1.9.13.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-avro-serializer-4.1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-avro-converter-4.1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-serializer-4.1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-schema-registry-client-4.1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-avro-serde-4.1.2.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/paranamer-2.7.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/snappy-java-1.1.1.3.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/xz-1.5.jar:/opt/landoop/kafka/share/java/confluent-common/build-tools-4.1.2.jar:/opt/landoop/kafka/share/java/confluent-common/common-config-4.1.2.jar:/opt/landoop/kafka/share/java/confluent-common/common-metrics-4.1.2.jar:/opt/landoop/kafka/share/java/confluent-common/common-utils-4.1.2.jar:/opt/landoop/kafka/share/java/confluent-common/jline-0.9.94.jar:/opt/landoop/kafka/share/java/confluent-common/log4j-1.2.17.jar:/opt/landoop/kafka/share/java/confluent-common/netty-3.10.5.Final.jar:/opt/landoop/kafka/share/java/confluent-common/slf4j-api-1.7.25.jar:/opt/landoop/kafka/share/java/confluent-common/zkclient-0.10.jar:/opt/landoop/kafka/share/java/confluent-common/zookeeper-3.4.10.jar:/opt/landoop/kafka/share/java/landoop-common/aggdesigner-algorithm-6.0.jar:/opt/landoop/kafka/share/java/landoop-common/antlr4-runtime-4.7.jar:/opt/landoop/kafka/share/java/landoop-common/aopalliance-repackaged-2.5.0-b30.jar:/opt/landoop/kafka/share/java/landoop-common/avatica-core-1.9.0.jar:/opt/landoop/kafka/share/java/landoop-common/avatica-metrics-1.9.0.jar:/opt/landoop/kafka/share/java/landoop-common/avro-1.8.1.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-core_2.11-1.6.4.jar:/opt/landoop/kafka/share/java/landoop-common/avro4s-macros_2.11-1.6.4.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-core-1.12.0.jar:/opt/landoop/kafka/share/java/landoop-common/calcite-linq4j-1.12.0.jar:/opt/landoop/kafka/share/java/landoop-common/classmate-1.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-config-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-metrics-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-utils-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compiler-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/commons-compress-1.8.1.jar:/opt/landoop/kafka/share/java/landoop-common/commons-dbcp-1.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang-2.4.jar:/opt/landoop/kafka/share/java/landoop-common/commons-lang3-3.2.jar:/opt/landoop/kafka/share/java/landoop-common/commons-logging-1.1.3.jar:/opt/landoop/kafka/share/java/landoop-common/commons-pool-1.5.4.jar:/opt/landoop/kafka/share/java/landoop-common/connect-api-1.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/connect-json-1.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/guava-19.0.jar:/opt/landoop/kafka/share/java/landoop-common/hibernate-validator-5.1.3.Final.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-api-2.5.0-b30.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-locator-2.5.0-b30.jar:/opt/landoop/kafka/share/java/landoop-common/hk2-utils-2.5.0-b30.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-annotations-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-core-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-core-asl-1.9.13.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-databind-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-base-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-json-provider-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-mapper-asl-1.9.13.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-jaxb-annotations-2.9.4.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-paranamer-2.9.1.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-module-scala_2.11-2.9.1.jar:/opt/landoop/kafka/share/java/landoop-common/janino-2.7.6.jar:/opt/landoop/kafka/share/java/landoop-common/javax.el-2.2.4.jar:/opt/landoop/kafka/share/java/landoop-common/javax.el-api-2.2.4.jar:/opt/landoop/kafka/share/java/landoop-common/javax.inject-2.5.0-b30.jar:/opt/landoop/kafka/share/java/landoop-common/jboss-logging-3.1.3.GA.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-bean-validation-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-client-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-common-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-container-servlet-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-container-servlet-core-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-guava-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-media-jaxb-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jersey-server-2.25.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jaas-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jmx-9.2.24.v20180105.jar:/opt/landoop/kafka/share/java/landoop-common/jline-0.9.94.jar:/opt/landoop/kafka/share/java/landoop-common/json-sql_2.11-1.0.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-ast_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-core_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-jackson_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-native_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/json4s-scalap_2.11-3.4.1.jar:/opt/landoop/kafka/share/java/landoop-common/jsr305-3.0.1.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-avro-serializer-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-clients-1.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-avro-converter-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-smt_2.11-1.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-client-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka_2.11-1.1.0-cp1.jar:/opt/landoop/kafka/share/java/landoop-common/kcql-2.6.1.jar:/opt/landoop/kafka/share/java/landoop-common/lz4-java-1.4.jar:/opt/landoop/kafka/share/java/landoop-common/macro-compat_2.11-1.1.1.jar:/opt/landoop/kafka/share/java/landoop-common/netty-3.10.5.Final.jar:/opt/landoop/kafka/share/java/landoop-common/paranamer-2.8.jar:/opt/landoop/kafka/share/java/landoop-common/rest-utils-4.1.0.jar:/opt/landoop/kafka/share/java/landoop-common/scala-compiler-2.11.7.jar:/opt/landoop/kafka/share/java/landoop-common/scala-parser-combinators_2.11-1.0.4.jar:/opt/landoop/kafka/share/java/landoop-common/scala-xml_2.11-1.0.5.jar:/opt/landoop/kafka/share/java/landoop-common/shapeless_2.11-2.3.2.jar:/opt/landoop/kafka/share/java/landoop-common/sql-core_2.11-1.0.jar:/opt/landoop/kafka/share/java/landoop-common/xz-1.5.jar\n\tos.spec = Linux, amd64, 3.10.0-693.17.1.el7.x86_64\n\tos.vcpus = 32\n (org.apache.kafka.connect.runtime.WorkerInfo:71)\n[2018-12-14 06:10:04,489] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:76)\n[2018-12-14 06:10:04,533] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-couchbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:05,320] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-couchbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:05,321] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,321] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,358] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-dbvisitreplicate (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:05,387] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-dbvisitreplicate/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:05,387] INFO Added plugin 'com.dbvisit.replicate.kafkaconnect.ReplicateSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,389] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:05,539] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:05,539] INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,539] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,540] INFO Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,540] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,543] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:05,651] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:05,651] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,658] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-postgres (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:05,767] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-postgres/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:05,768] INFO Added plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:05,786] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:06,143] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:06,144] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:06,146] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:08,771] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:08,772] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,772] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,772] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,772] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,820] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:08,943] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:08,943] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,943] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:08,956] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:11,291] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:11,291] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:11,332] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-twitter (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:194)\n[2018-12-14 06:10:12,443] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-twitter/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:12,444] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:12,444] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,269] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:217)\n[2018-12-14 06:10:14,269] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,269] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,270] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,271] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,272] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,273] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,273] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,273] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:146)\n[2018-12-14 06:10:14,275] INFO Added aliases 'CouchbaseSinkConnector' and 'CouchbaseSink' to plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,275] INFO Added aliases 'CouchbaseSourceConnector' and 'CouchbaseSource' to plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,275] INFO Added aliases 'ReplicateSourceConnector' and 'ReplicateSource' to plugin 'com.dbvisit.replicate.kafkaconnect.ReplicateSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,275] INFO Added aliases 'TwitterSinkConnector' and 'TwitterSink' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,276] INFO Added aliases 'TwitterSourceConnector' and 'TwitterSource' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,276] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,276] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,276] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,277] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,278] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,279] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,279] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:351)\n[2018-12-14 06:10:14,280] INFO Added alias 'Transformation' to plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,280] INFO Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,280] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,280] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,281] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,281] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,282] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:348)\n[2018-12-14 06:10:14,299] INFO StandaloneConfig values: \n\taccess.control.allow.methods = \n\taccess.control.allow.origin = \n\tbootstrap.servers = [localhost:9092]\n\theader.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter\n\tinternal.key.converter = class org.apache.kafka.connect.json.JsonConverter\n\tinternal.value.converter = class org.apache.kafka.connect.json.JsonConverter\n\tkey.converter = class io.confluent.connect.avro.AvroConverter\n\tlisteners = null\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\toffset.flush.interval.ms = 5000\n\toffset.flush.timeout.ms = 5000\n\toffset.storage.file.filename = coyote_connect.offset\n\tplugin.path = [/opt/landoop/connectors/third-party]\n\trest.advertised.host.name = null\n\trest.advertised.listener = null\n\trest.advertised.port = null\n\trest.host.name = null\n\trest.port = 38783\n\tssl.client.auth = none\n\ttask.shutdown.graceful.timeout.ms = 5000\n\tvalue.converter = class io.confluent.connect.avro.AvroConverter\n (org.apache.kafka.connect.runtime.standalone.StandaloneConfig:279)\n[2018-12-14 06:10:14,301] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)\n[2018-12-14 06:10:14,306] INFO AdminClientConfig values: \n\tbootstrap.servers = [localhost:9092]\n\tclient.id = \n\tconnections.max.idle.ms = 300000\n\tmetadata.max.age.ms = 300000\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\treceive.buffer.bytes = 65536\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 120000\n\tretries = 5\n\tretry.backoff.ms = 100\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.mechanism = GSSAPI\n\tsecurity.protocol = PLAINTEXT\n\tsend.buffer.bytes = 131072\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\n\tssl.endpoint.identification.algorithm = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLS\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n (org.apache.kafka.clients.admin.AdminClientConfig:279)\n[2018-12-14 06:10:14,346] WARN The configuration 'zookeeper' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,346] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,346] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,346] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,346] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,346] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,347] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,348] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2018-12-14 06:10:14,349] INFO Kafka version : 1.1.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2018-12-14 06:10:14,349] INFO Kafka commitId : 4dae083af486eaed (org.apache.kafka.common.utils.AppInfoParser:110)\n[2018-12-14 06:10:14,580] INFO Cluster ID: SOkEM7P5RSig64DyV7-uXA (org.apache.kafka.clients.Metadata:265)\n[2018-12-14 06:10:14,586] INFO Kafka cluster ID: SOkEM7P5RSig64DyV7-uXA (org.apache.kafka.connect.util.ConnectUtils:59)\n[2018-12-14 06:10:14,608] INFO Logging initialized @10751ms (org.eclipse.jetty.util.log:186)\n[2018-12-14 06:10:14,629] INFO Added connector for http://:38783 (org.apache.kafka.connect.runtime.rest.RestServer:110)\n[2018-12-14 06:10:14,751] INFO Advertised URI: http://172.17.0.4:38783/ (org.apache.kafka.connect.runtime.rest.RestServer:248)\n[2018-12-14 06:10:14,759] INFO Kafka version : 1.1.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2018-12-14 06:10:14,759] INFO Kafka commitId : 4dae083af486eaed (org.apache.kafka.common.utils.AppInfoParser:110)\n[2018-12-14 06:10:14,884] INFO JsonConverterConfig values: \n\tconverter.type = key\n\tschemas.cache.size = 1000\n\tschemas.enable = false\n (org.apache.kafka.connect.json.JsonConverterConfig:279)\n[2018-12-14 06:10:14,885] INFO JsonConverterConfig values: \n\tconverter.type = value\n\tschemas.cache.size = 1000\n\tschemas.enable = false\n (org.apache.kafka.connect.json.JsonConverterConfig:279)\n[2018-12-14 06:10:14,891] INFO Kafka Connect standalone worker initialization took 10414ms (org.apache.kafka.connect.cli.ConnectStandalone:92)\n[2018-12-14 06:10:14,891] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:49)\n[2018-12-14 06:10:14,891] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:71)\n[2018-12-14 06:10:14,892] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:139)\n[2018-12-14 06:10:14,892] INFO Starting FileOffsetBackingStore with file coyote_connect.offset (org.apache.kafka.connect.storage.FileOffsetBackingStore:59)\n[2018-12-14 06:10:14,894] INFO Worker started (org.apache.kafka.connect.runtime.Worker:144)\n[2018-12-14 06:10:14,894] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:73)\n[2018-12-14 06:10:14,894] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:155)\n[2018-12-14 06:10:15,006] INFO jetty-9.2.24.v20180105 (org.eclipse.jetty.server.Server:327)\n[2018-12-14 06:10:15,452] INFO HV000001: Hibernate Validator 5.1.3.Final (org.hibernate.validator.internal.util.Version:27)\n[2018-12-14 06:10:15,718] INFO Started o.e.j.s.ServletContextHandler@19bedeb8{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:744)\n[2018-12-14 06:10:15,726] INFO Started http_38783@1b90fee4{HTTP/1.1}{0.0.0.0:38783} (org.eclipse.jetty.server.ServerConnector:266)\n[2018-12-14 06:10:15,726] INFO Started @11869ms (org.eclipse.jetty.server.Server:379)\n[2018-12-14 06:10:15,727] INFO Advertised URI: http://172.17.0.4:38783/ (org.apache.kafka.connect.runtime.rest.RestServer:248)\n[2018-12-14 06:10:15,727] INFO REST server listening at http://172.17.0.4:38783/, advertising URL http://172.17.0.4:38783/ (org.apache.kafka.connect.runtime.rest.RestServer:207)\n[2018-12-14 06:10:15,727] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)\n[2018-12-14 06:10:15,841] INFO ConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig:279)\n[2018-12-14 06:10:15,842] INFO EnrichedConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2018-12-14 06:10:15,842] INFO Creating connector coyote-ca-1544767803315 of type io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:202)\n[2018-12-14 06:10:15,846] INFO Instantiated connector coyote-ca-1544767803315 with version 4.1.2 of type class io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:205)\n[2018-12-14 06:10:15,846] INFO JdbcSourceConnectorConfig values: \n\tbatch.max.rows = 100\n\tconnection.attempts = 3\n\tconnection.backoff.ms = 10000\n\tconnection.password = null\n\tconnection.url = jdbc:sqlite:coyote_test.sqlite\n\tconnection.user = null\n\tincrementing.column.name = id\n\tmode = incrementing\n\tnumeric.mapping = null\n\tnumeric.precision.mapping = false\n\tpoll.interval.ms = 5000\n\tquery = \n\tschema.pattern = null\n\ttable.blacklist = []\n\ttable.poll.interval.ms = 60000\n\ttable.types = [TABLE]\n\ttable.whitelist = []\n\ttimestamp.column.name = \n\ttimestamp.delay.interval.ms = 0\n\ttopic.prefix = coyote-ca-\n\tvalidate.non.null = true\n (io.confluent.connect.jdbc.source.JdbcSourceConnectorConfig:279)\n[2018-12-14 06:10:15,851] INFO Finished creating connector coyote-ca-1544767803315 (org.apache.kafka.connect.runtime.Worker:224)\n[2018-12-14 06:10:15,854] INFO SourceConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)\n[2018-12-14 06:10:15,854] INFO EnrichedConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2018-12-14 06:10:15,857] INFO Creating task coyote-ca-1544767803315-0 (org.apache.kafka.connect.runtime.Worker:362)\n[2018-12-14 06:10:15,857] INFO ConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig:279)\n[2018-12-14 06:10:15,857] INFO EnrichedConnectorConfig values: \n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1544767803315\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2018-12-14 06:10:15,858] INFO TaskConfig values: \n\ttask.class = class io.confluent.connect.jdbc.source.JdbcSourceTask\n (org.apache.kafka.connect.runtime.TaskConfig:279)\n[2018-12-14 06:10:15,859] INFO Instantiated task coyote-ca-1544767803315-0 with version 4.1.2 of type io.confluent.connect.jdbc.source.JdbcSourceTask (org.apache.kafka.connect.runtime.Worker:377)\n[2018-12-14 06:10:15,865] INFO AvroConverterConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.connect.avro.AvroConverterConfig:179)\n[2018-12-14 06:10:16,035] INFO KafkaAvroSerializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179)\n[2018-12-14 06:10:16,039] INFO KafkaAvroDeserializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tspecific.avro.reader = false\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179)\n[2018-12-14 06:10:16,079] INFO AvroDataConfig values: \n\tschemas.cache.config = 1000\n\tenhanced.avro.schema.support = false\n\tconnect.meta.data = true\n (io.confluent.connect.avro.AvroDataConfig:179)\n[2018-12-14 06:10:16,079] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task coyote-ca-1544767803315-0 using the worker config (org.apache.kafka.connect.runtime.Worker:400)\n[2018-12-14 06:10:16,079] INFO AvroConverterConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.connect.avro.AvroConverterConfig:179)\n[2018-12-14 06:10:16,080] INFO KafkaAvroSerializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.kafka.serializers.KafkaAvroSerializerConfig:179)\n[2018-12-14 06:10:16,080] INFO KafkaAvroDeserializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tauto.register.schemas = true\n\tmax.schemas.per.subject = 1000\n\tbasic.auth.credentials.source = URL\n\tschema.registry.basic.auth.user.info = [hidden]\n\tspecific.avro.reader = false\n\tvalue.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n\tkey.subject.name.strategy = class io.confluent.kafka.serializers.subject.TopicNameStrategy\n (io.confluent.kafka.serializers.KafkaAvroDeserializerConfig:179)\n[2018-12-14 06:10:16,080] INFO AvroDataConfig values: \n\tschemas.cache.config = 1000\n\tenhanced.avro.schema.support = false\n\tconnect.meta.data = true\n (io.confluent.connect.avro.AvroDataConfig:179)\n[2018-12-14 06:10:16,080] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task coyote-ca-1544767803315-0 using the worker config (org.apache.kafka.connect.runtime.Worker:406)\n[2018-12-14 06:10:16,080] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task coyote-ca-1544767803315-0 using the worker config (org.apache.kafka.connect.runtime.Worker:412)\n[2018-12-14 06:10:16,088] INFO ProducerConfig values: \n\tacks = all\n\tbatch.size = 16384\n\tbootstrap.servers = [localhost:9092]\n\tbuffer.memory = 33554432\n\tclient.id = \n\tcompression.type = none\n\tconnections.max.idle.ms = 540000\n\tenable.idempotence = false\n\tinterceptor.classes = []\n\tkey.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\n\tlinger.ms = 0\n\tmax.block.ms = 9223372036854775807\n\tmax.in.flight.requests.per.connection = 1\n\tmax.request.size = 1048576\n\tmetadata.max.age.ms = 300000\n\tmetric.reporters = []\n\tmetrics.num.samples = 2\n\tmetrics.recording.level = INFO\n\tmetrics.sample.window.ms = 30000\n\tpartitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner\n\treceive.buffer.bytes = 32768\n\treconnect.backoff.max.ms = 1000\n\treconnect.backoff.ms = 50\n\trequest.timeout.ms = 2147483647\n\tretries = 2147483647\n\tretry.backoff.ms = 100\n\tsasl.jaas.config = null\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\n\tsasl.kerberos.min.time.before.relogin = 60000\n\tsasl.kerberos.service.name = null\n\tsasl.kerberos.ticket.renew.jitter = 0.05\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\n\tsasl.mechanism = GSSAPI\n\tsecurity.protocol = PLAINTEXT\n\tsend.buffer.bytes = 131072\n\tssl.cipher.suites = null\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\n\tssl.endpoint.identification.algorithm = null\n\tssl.key.password = null\n\tssl.keymanager.algorithm = SunX509\n\tssl.keystore.location = null\n\tssl.keystore.password = null\n\tssl.keystore.type = JKS\n\tssl.protocol = TLS\n\tssl.provider = null\n\tssl.secure.random.implementation = null\n\tssl.trustmanager.algorithm = PKIX\n\tssl.truststore.location = null\n\tssl.truststore.password = null\n\tssl.truststore.type = JKS\n\ttransaction.timeout.ms = 60000\n\ttransactional.id = null\n\tvalue.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer\n (org.apache.kafka.clients.producer.ProducerConfig:279)\n[2018-12-14 06:10:16,108] INFO Kafka version : 1.1.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2018-12-14 06:10:16,109] INFO Kafka commitId : 4dae083af486eaed (org.apache.kafka.common.utils.AppInfoParser:110)\n[2018-12-14 06:10:16,117] INFO Created connector coyote-ca-1544767803315 (org.apache.kafka.connect.cli.ConnectStandalone:104)\n[2018-12-14 06:10:16,118] INFO JdbcSourceTaskConfig values: \n\tbatch.max.rows = 100\n\tconnection.attempts = 3\n\tconnection.backoff.ms = 10000\n\tconnection.password = null\n\tconnection.url = jdbc:sqlite:coyote_test.sqlite\n\tconnection.user = null\n\tincrementing.column.name = id\n\tmode = incrementing\n\tnumeric.mapping = null\n\tnumeric.precision.mapping = false\n\tpoll.interval.ms = 5000\n\tquery = \n\tschema.pattern = null\n\ttable.blacklist = []\n\ttable.poll.interval.ms = 60000\n\ttable.types = [TABLE]\n\ttable.whitelist = []\n\ttables = [accounts]\n\ttimestamp.column.name = \n\ttimestamp.delay.interval.ms = 0\n\ttopic.prefix = coyote-ca-\n\tvalidate.non.null = true\n (io.confluent.connect.jdbc.source.JdbcSourceTaskConfig:279)\n[2018-12-14 06:10:16,148] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:190)\n[2018-12-14 06:10:16,355] WARN [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {coyote-ca-accounts=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:882)\n[2018-12-14 06:10:16,357] INFO Cluster ID: SOkEM7P5RSig64DyV7-uXA (org.apache.kafka.clients.Metadata:265)\n[2018-12-14 06:10:21,116] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:21,117] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:21,125] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Finished commitOffsets successfully in 8 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:452)\n[2018-12-14 06:10:26,126] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:26,126] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:31,127] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:31,127] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:36,128] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:36,128] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:41,128] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:41,129] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:46,129] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:46,130] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:48,337] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:65)\n[2018-12-14 06:10:48,341] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:211)\n[2018-12-14 06:10:48,346] INFO Stopped http_38783@1b90fee4{HTTP/1.1}{0.0.0.0:38783} (org.eclipse.jetty.server.ServerConnector:306)\n[2018-12-14 06:10:48,377] INFO Stopped o.e.j.s.ServletContextHandler@19bedeb8{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:865)\n[2018-12-14 06:10:48,379] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:222)\n[2018-12-14 06:10:48,379] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:77)\n[2018-12-14 06:10:48,379] INFO Stopping task coyote-ca-1544767803315-0 (org.apache.kafka.connect.runtime.Worker:478)\n[2018-12-14 06:10:51,159] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:353)\n[2018-12-14 06:10:51,160] INFO WorkerSourceTask{id=coyote-ca-1544767803315-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:370)\n[2018-12-14 06:10:51,160] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1054)\n[2018-12-14 06:10:51,166] INFO Stopping connector coyote-ca-1544767803315 (org.apache.kafka.connect.runtime.Worker:305)\n[2018-12-14 06:10:51,167] INFO Stopping table monitoring thread (io.confluent.connect.jdbc.JdbcSourceConnector:166)\n[2018-12-14 06:10:51,168] INFO Stopped connector coyote-ca-1544767803315 (org.apache.kafka.connect.runtime.Worker:321)\n[2018-12-14 06:10:51,169] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:151)\n[2018-12-14 06:10:51,169] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:67)\n[2018-12-14 06:10:51,170] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:172)\n[2018-12-14 06:10:51,171] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:87)\n[2018-12-14 06:10:51,171] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:70)\n"
2018/12/14 06:10:54 Success, command 'timeout 10
kafka-console-consumer --new-consumer
                       --bootstrap-server localhost:9092
                       --topic coyote-ca-accounts
                       --from-beginning
                       --timeout-ms 10000
                       --max-messages 2
', test 'Run Console Consumer (basic kafka)'. Stdout: "\x00\x00\x00\x00\v\x02\x02\nalice\n\x00\x00\x00\x00\v\x04\x02\x06bob\n"
2018/12/14 06:10:55 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote-ca-accounts --delete', test 'Delete Connect Standalone Test Topic (basic kafka)'. Stdout: "Topic coyote-ca-accounts is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2018/12/14 06:10:55 Success, command 'rm -rf coyote_test.sqlite coyote_sqlite_connector.properties coyote_connect_standalone.properties coyote_connect.offset', test ''. Stdout: ""
2018/12/14 06:10:55 no errors