2019/04/23 06:08:09 Starting coyote-tester
2019/04/23 06:08:09 Starting processing group: [ Brokers ]
2019/04/23 06:08:22 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"
2019/04/23 06:08:25 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_basic_1555999702825 --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_1555999702825\".\n"
2019/04/23 06:08:27 Success, command 'kafka-topics --zookeeper localhost:2181 --list', test 'List Topics (basic kafka)'. Stdout: "__consumer_offsets\n_schemas\ncoyote_basic_1555999702825\n"
2019/04/23 06:08:39 Success, command 'kafka-producer-perf-test --topic coyote_basic_1555999702825 --throughput 100000 --record-size 1000 --num-records 500000
                         --producer-props bootstrap.servers="localhost:9092"
', test 'Performance Test (basic kafka)'. Stdout: "174193 records sent, 34838.6 records/sec (33.22 MB/sec), 817.3 ms avg latency, 1217.0 max latency.\n292176 records sent, 58435.2 records/sec (55.73 MB/sec), 567.9 ms avg latency, 723.0 max latency.\n500000 records sent, 47998.464049 records/sec (45.77 MB/sec), 646.63 ms avg latency, 1217.00 ms max latency, 598 ms 50th, 1027 ms 95th, 1202 ms 99th, 1215 ms 99.9th.\n"
2019/04/23 06:08:39 Starting processing group: [ REST Proxy ]
2019/04/23 06:08:43 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"
2019/04/23 06:08:43 Success, command 'curl -vs --stderr - "http://localhost:8082/topics"', test 'List Topics (rest proxy)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 1 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n* Expire in 0 ms for 1 (transfer 0x55e640152620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55e640152620)\n* Expire in 200 ms for 4 (transfer 0x55e640152620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:08:43 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 161\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n{ [161 bytes data]\n[\"_schemas\",\"backblaze_smart\",\"coyote_basic_1555999702825\",\"nyc_yellow_taxi_trip_data\",\"sea_vessel_position_reports\",\"telecom_italia_data\",\"telecom_italia_grid\"]* Connection #0 to host localhost left intact\n"
2019/04/23 06:08:43 Success, command 'curl -vs --stderr - "http://localhost:8082/topics/coyote_basic_1555999702825"', test 'Topic Information (rest proxy)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 1 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n* Expire in 0 ms for 1 (transfer 0x55fc37c80620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55fc37c80620)\n* Expire in 200 ms for 4 (transfer 0x55fc37c80620)\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /topics/coyote_basic_1555999702825 HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:08:43 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 971\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n{ [971 bytes data]\n{\"name\":\"coyote_basic_1555999702825\",\"configs\":{\"message.downconversion.enable\":\"true\",\"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\",\"message.timestamp.type\":\"CreateTime\",\"message.format.version\":\"2.0-IV1\",\"segment.bytes\":\"104857600\",\"unclean.leader.election.enable\":\"false\",\"max.message.bytes\":\"1000012\",\"retention.ms\":\"60000\",\"flush.ms\":\"9223372036854775807\",\"delete.retention.ms\":\"86400000\",\"leader.replication.throttled.replicas\":\"\",\"min.insync.replicas\":\"1\",\"flush.messages\":\"9223372036854775807\",\"compression.type\":\"producer\",\"index.interval.bytes\":\"4096\",\"min.cleanable.dirty.ratio\":\"0.5\"},\"partitions\":[{\"partition\":0,\"leader\":0,\"replicas\":[{\"broker\":0,\"leader\":true,\"in_sync\":true}]}]}* Connection #0 to host localhost left intact\n"
2019/04/23 06:08:43 Success, command 'curl -vs --stderr - "http://localhost:8082/topics/coyote_basic_1555999702825/partitions"', test 'Topic Partitions (rest proxy)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 1 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n* Expire in 0 ms for 1 (transfer 0x559b2ed65620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x559b2ed65620)\n* Expire in 200 ms for 4 (transfer 0x559b2ed65620)\n* Connected to localhost (127.0.0.1) port 8082 (#0)\n> GET /topics/coyote_basic_1555999702825/partitions HTTP/1.1\r\n> Host: localhost:8082\r\n> User-Agent: curl/7.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:08:43 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 83\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:08:45 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_basic_1555999702825 --delete', test 'Delete Topic (basic kafka)'. Stdout: "Topic coyote_basic_1555999702825 is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2019/04/23 06:08:46 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: "* Expire in 0 ms for 6 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 1 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n* Expire in 0 ms for 1 (transfer 0x55fa89e17620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55fa89e17620)\n* Expire in 200 ms for 4 (transfer 0x55fa89e17620)\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.64.0\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: Tue, 23 Apr 2019 06:08:45 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 112\r\n< Server: Jetty(9.4.11.v20180605)\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\":3}* Connection #0 to host localhost left intact\n"
2019/04/23 06:08:46 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: "* Expire in 0 ms for 6 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 1 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n* Expire in 0 ms for 1 (transfer 0x5576d73cc620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5576d73cc620)\n* Expire in 200 ms for 4 (transfer 0x5576d73cc620)\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.64.0\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: Tue, 23 Apr 2019 06:08:46 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 106\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:08:51 Success, command 'sleep 5', test ''. Stdout: ""
2019/04/23 06:08:52 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: "* Expire in 0 ms for 6 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 1 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n* Expire in 0 ms for 1 (transfer 0x55b0d1b5a620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55b0d1b5a620)\n* Expire in 200 ms for 4 (transfer 0x55b0d1b5a620)\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.64.0\r\n> Accept: application/vnd.kafka.avro.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:08:51 GMT\r\n< Content-Type: application/vnd.kafka.avro.v1+json\r\n< Content-Length: 94\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:08:52 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: "* Expire in 0 ms for 6 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 1 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n* Expire in 0 ms for 1 (transfer 0x5641a950f620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5641a950f620)\n* Expire in 200 ms for 4 (transfer 0x5641a950f620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Tue, 23 Apr 2019 06:08:52 GMT\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2019/04/23 06:08:57 Success, command 'sleep 5', test ''. Stdout: ""
2019/04/23 06:08:59 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"
2019/04/23 06:08:59 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: "* Expire in 0 ms for 6 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 1 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n* Expire in 0 ms for 1 (transfer 0x558f0d8a5620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x558f0d8a5620)\n* Expire in 200 ms for 4 (transfer 0x558f0d8a5620)\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.64.0\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: Tue, 23 Apr 2019 06:08:59 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 115\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:08:59 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: "* Expire in 0 ms for 6 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 1 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n* Expire in 0 ms for 1 (transfer 0x55d20060f620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55d20060f620)\n* Expire in 200 ms for 4 (transfer 0x55d20060f620)\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.64.0\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: Tue, 23 Apr 2019 06:08:59 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 106\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:01 Success, command 'sleep 2', test ''. Stdout: ""
2019/04/23 06:09:01 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: "* Expire in 0 ms for 6 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 1 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n* Expire in 0 ms for 1 (transfer 0x556e5c572620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x556e5c572620)\n* Expire in 200 ms for 4 (transfer 0x556e5c572620)\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.64.0\r\n> Accept: application/vnd.kafka.json.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:01 GMT\r\n< Content-Type: application/vnd.kafka.json.v1+json\r\n< Content-Length: 88\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:01 Success, command 'curl -vs --stderr - -X DELETE "http://localhost:8082/consumers/coyote-json/instances/a-consumer"', test 'Delete JSON Consumer (rest proxy)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 1 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n* Expire in 0 ms for 1 (transfer 0x562a90349620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x562a90349620)\n* Expire in 200 ms for 4 (transfer 0x562a90349620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Tue, 23 Apr 2019 06:09:01 GMT\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:03 Success, command 'sleep 2', test ''. Stdout: ""
2019/04/23 06:09:05 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"
2019/04/23 06:09:05 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: "* Expire in 0 ms for 6 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 1 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n* Expire in 0 ms for 1 (transfer 0x5588a1548620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5588a1548620)\n* Expire in 200 ms for 4 (transfer 0x5588a1548620)\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.64.0\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: Tue, 23 Apr 2019 06:09:05 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 115\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:05 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: "* Expire in 0 ms for 6 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 1 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n* Expire in 0 ms for 1 (transfer 0x55a32fa48620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55a32fa48620)\n* Expire in 200 ms for 4 (transfer 0x55a32fa48620)\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.64.0\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: Tue, 23 Apr 2019 06:09:05 GMT\r\n< Content-Type: application/vnd.kafka.v1+json\r\n< Content-Length: 108\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:07 Success, command 'sleep 2', test ''. Stdout: ""
2019/04/23 06:09:07 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: "* Expire in 0 ms for 6 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 1 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n* Expire in 0 ms for 1 (transfer 0x5569e0006620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5569e0006620)\n* Expire in 200 ms for 4 (transfer 0x5569e0006620)\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.64.0\r\n> Accept: application/vnd.kafka.binary.v1+json\r\n> \r\n< HTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:07 GMT\r\n< Content-Type: application/vnd.kafka.binary.v1+json\r\n< Content-Length: 87\r\n< Server: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:07 Success, command 'curl -vs --stderr - -XDELETE "http://localhost:8082/consumers/coyote-binary/instances/a-consumer"', test 'Delete Binary Consumer (rest proxy)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 1 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n* Expire in 0 ms for 1 (transfer 0x55876a8b1620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55876a8b1620)\n* Expire in 200 ms for 4 (transfer 0x55876a8b1620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Tue, 23 Apr 2019 06:09:07 GMT\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:12 Success, command 'sleep 5', test ''. Stdout: ""
2019/04/23 06:09:14 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"
2019/04/23 06:09:14 Starting processing group: [ Schema Registry ]
2019/04/23 06:09:14 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: "* Expire in 0 ms for 6 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 1 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n* Expire in 0 ms for 1 (transfer 0x5624eab2d620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5624eab2d620)\n* Expire in 200 ms for 4 (transfer 0x5624eab2d620)\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.64.0\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: Tue, 23 Apr 2019 06:09:14 GMT\r\nDate: Tue, 23 Apr 2019 06:09:14 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [8 bytes data]\n{\"id\":8}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:14 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/subjects"', test 'List subjects (schema registry)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 1 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n* Expire in 0 ms for 1 (transfer 0x5556dcb9d620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5556dcb9d620)\n* Expire in 200 ms for 4 (transfer 0x5556dcb9d620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:14 GMT\r\nDate: Tue, 23 Apr 2019 06:09:14 GMT\r\n< Content-Type: application/vnd.schemaregistry.v1+json\r\nContent-Type: application/vnd.schemaregistry.v1+json\r\n< Content-Length: 253\r\nContent-Length: 253\r\n< Server: Jetty(9.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [253 bytes data]\n[\"coyote-test-avro-value\",\"telecom_italia_data-key\",\"telecom_italia_grid-key\",\"telecom_italia_data-value\",\"coyote_basic\",\"nyc_yellow_taxi_trip_data-value\",\"sea_vessel_position_reports-key\",\"sea_vessel_position_reports-value\",\"telecom_italia_grid-value\"]* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:14 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/subjects/coyote_basic/versions"', test 'List Schema versions (schema registry)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 1 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n* Expire in 0 ms for 1 (transfer 0x5582c7e2b620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5582c7e2b620)\n* Expire in 200 ms for 4 (transfer 0x5582c7e2b620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:14 GMT\r\nDate: Tue, 23 Apr 2019 06:09:14 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [3 bytes data]\n[1]* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:14 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: "* Expire in 0 ms for 6 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 1 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n* Expire in 0 ms for 1 (transfer 0x555f714df620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x555f714df620)\n* Expire in 200 ms for 4 (transfer 0x555f714df620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:14 GMT\r\nDate: Tue, 23 Apr 2019 06:09:14 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\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"
2019/04/23 06:09:15 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: "* Expire in 0 ms for 6 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 1 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n* Expire in 0 ms for 1 (transfer 0x55da7f87b620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55da7f87b620)\n* Expire in 200 ms for 4 (transfer 0x55da7f87b620)\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.64.0\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: Tue, 23 Apr 2019 06:09:14 GMT\r\nDate: Tue, 23 Apr 2019 06:09:14 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [8 bytes data]\n{\"id\":3}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:15 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: "* Expire in 0 ms for 6 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 1 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n* Expire in 0 ms for 1 (transfer 0x55b4ac85a620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55b4ac85a620)\n* Expire in 200 ms for 4 (transfer 0x55b4ac85a620)\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.64.0\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: Tue, 23 Apr 2019 06:09:15 GMT\r\nDate: Tue, 23 Apr 2019 06:09:15 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [23 bytes data]\n{\"is_compatible\":false}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:15 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8081/config"', test 'Get Schema Registry Configuration (schema registry)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 1 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n* Expire in 0 ms for 1 (transfer 0x5595093f2620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5595093f2620)\n* Expire in 200 ms for 4 (transfer 0x5595093f2620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:15 GMT\r\nDate: Tue, 23 Apr 2019 06:09:15 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [33 bytes data]\n{\"compatibilityLevel\":\"BACKWARD\"}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:15 Starting processing group: [ Connect ]
2019/04/23 06:09:25 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: "[]"
2019/04/23 06:09:25 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8083/connectors"', test 'Get list of Connectors (connect distributed)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 1 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n* Expire in 0 ms for 1 (transfer 0x5561c95d0620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x5561c95d0620)\n* Expire in 200 ms for 4 (transfer 0x5561c95d0620)\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.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:25 GMT\r\nDate: Tue, 23 Apr 2019 06:09:25 GMT\r\n< Content-Type: application/json\r\nContent-Type: application/json\r\n< Content-Length: 2\r\nContent-Length: 2\r\n< Server: Jetty(9.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [2 bytes data]\n[]* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:26 Success, command 'curl -vs --stderr - -X POST -H "Content-Type: application/json"
     --data '{ "name": "coyote_test_console_source-1555999765127",
       "config": {"connector.class":"org.apache.kafka.connect.file.FileStreamSourceConnector","tasks.max":"1","topic":"coyote_cd-1555999765127","file":"/etc/fstab"}}'
     "http://localhost:8083/connectors"
', test 'Create a Console Connector (connect distributed)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 1 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n* Expire in 0 ms for 1 (transfer 0x555e10264620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x555e10264620)\n* Expire in 200 ms for 4 (transfer 0x555e10264620)\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.64.0\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: Tue, 23 Apr 2019 06:09:25 GMT\r\n< Location: http://localhost:8083/connectors/coyote_test_console_source-1555999765127\r\n< Content-Type: application/json\r\n< Content-Length: 281\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n{ [281 bytes data]\n{\"name\":\"coyote_test_console_source-1555999765127\",\"config\":{\"connector.class\":\"org.apache.kafka.connect.file.FileStreamSourceConnector\",\"tasks.max\":\"1\",\"topic\":\"coyote_cd-1555999765127\",\"file\":\"/etc/fstab\",\"name\":\"coyote_test_console_source-1555999765127\"},\"tasks\":[],\"type\":null}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:36 Success, command 'sleep 10', test 'Sleep a bit to let the connector spawn and work'. Stdout: ""
2019/04/23 06:09:36 Success, command 'curl -vs --stderr - -XGET -i "http://localhost:8083/connectors/coyote_test_console_source-1555999765127"', test 'Get Connector s Configuration (connect distributed)'. Stdout: "* Expire in 0 ms for 6 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 1 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n* Expire in 0 ms for 1 (transfer 0x563dee91e620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x563dee91e620)\n* Expire in 200 ms for 4 (transfer 0x563dee91e620)\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> GET /connectors/coyote_test_console_source-1555999765127 HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 200 OK\r\nHTTP/1.1 200 OK\r\n< Date: Tue, 23 Apr 2019 06:09:36 GMT\r\nDate: Tue, 23 Apr 2019 06:09:36 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.4.11.v20180605)\r\nServer: Jetty(9.4.11.v20180605)\r\n\r\n< \r\n{ [350 bytes data]\n{\"name\":\"coyote_test_console_source-1555999765127\",\"config\":{\"connector.class\":\"org.apache.kafka.connect.file.FileStreamSourceConnector\",\"name\":\"coyote_test_console_source-1555999765127\",\"topic\":\"coyote_cd-1555999765127\",\"file\":\"/etc/fstab\",\"tasks.max\":\"1\"},\"tasks\":[{\"connector\":\"coyote_test_console_source-1555999765127\",\"task\":0}],\"type\":\"source\"}* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:44 Success, command 'timeout 10
kafka-console-consumer --bootstrap-server localhost:9092
                       --topic coyote_cd-1555999765127
                       --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"
2019/04/23 06:09:52 Success, command 'timeout 10
kafka-console-consumer --bootstrap-server localhost:9092
                       --topic coyote_cd-1555999765127
                       --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"
2019/04/23 06:09:52 Success, command 'curl -vs --stderr - -XDELETE "http://localhost:8083/connectors/coyote_test_console_source-1555999765127"', test 'Delete connector'. Stdout: "* Expire in 0 ms for 6 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 1 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n* Expire in 0 ms for 1 (transfer 0x55a16122b620)\n*   Trying 127.0.0.1...\n* TCP_NODELAY set\n* Expire in 150000 ms for 3 (transfer 0x55a16122b620)\n* Expire in 200 ms for 4 (transfer 0x55a16122b620)\n* Connected to localhost (127.0.0.1) port 8083 (#0)\n> DELETE /connectors/coyote_test_console_source-1555999765127 HTTP/1.1\r\n> Host: localhost:8083\r\n> User-Agent: curl/7.64.0\r\n> Accept: */*\r\n> \r\n< HTTP/1.1 204 No Content\r\n< Date: Tue, 23 Apr 2019 06:09:52 GMT\r\n< Server: Jetty(9.4.11.v20180605)\r\n< \r\n* Connection #0 to host localhost left intact\n"
2019/04/23 06:09:57 Success, command 'sleep 5', test ''. Stdout: ""
2019/04/23 06:09:59 Success, command 'kafka-topics --zookeeper localhost:2181 --topic coyote_cd-1555999765127 --delete', test 'Delete Connect Distributes Test Topic (basic kafka)'. Stdout: "Topic coyote_cd-1555999765127 is marked for deletion.\nNote: This will have no impact if delete.topic.enable is not set to true.\n"
2019/04/23 06:09:59 Success, command 'rm -rf coyote_test.sqlite coyote_sqlite_connector.properties coyote_connect_standalone.properties coyote_connect.offset', test ''. Stdout: ""
2019/04/23 06:09:59 Success, command 'sqlite3 coyote_test.sqlite', test 'Create and Init SQLite database'. Stdout: ""
2019/04/23 06:09:59 Success, command 'tee coyote_sqlite_connector.properties', test 'Create coyote_sqlite_connector.properties'. Stdout: "name=coyote-ca-1555999799933\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"
2019/04/23 06:09:59 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\nrest.port=38783\nport=38783\nplugin.path=/opt/landoop/connectors/third-party\n"
2019/04/23 06:10:48 Success, command 'timeout -k 5 45 connect-standalone coyote_connect_standalone.properties coyote_sqlite_connector.properties', test 'Read SQLite into Topic (connect standalone)'. Stdout: "[2019-04-23 06:10:01,315] INFO Kafka Connect standalone worker initializing ... (org.apache.kafka.connect.cli.ConnectStandalone:67)\n[2019-04-23 06:10:01,341] 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, -Dcom.sun.management.jmxremote.local.only=false, -Djava.rmi.server.hostname=localhost, -Dcom.sun.management.jmxremote.rmi.port=9584, -Dkafka.logs.dir=/opt/landoop/kafka/logs, -Dlog4j.configuration=file:/var/run/connect/connect-log4j.properties\n\tjvm.spec = Oracle Corporation, OpenJDK 64-Bit Server VM, 1.8.0_201, 25.201-b08\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-b42.jar:/opt/landoop/kafka/share/java/kafka/argparse4j-0.7.0.jar:/opt/landoop/kafka/share/java/kafka/audience-annotations-0.5.0.jar:/opt/landoop/kafka/share/java/kafka/commons-lang3-3.5.jar:/opt/landoop/kafka/share/java/kafka/connect-api-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-basic-auth-extension-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-file-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-json-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-runtime-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/connect-transforms-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/guava-20.0.jar:/opt/landoop/kafka/share/java/kafka/hk2-api-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/hk2-locator-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/hk2-utils-2.5.0-b42.jar:/opt/landoop/kafka/share/java/kafka/jackson-annotations-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/jackson-core-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/jackson-databind-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-base-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/jackson-jaxrs-json-provider-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/jackson-module-jaxb-annotations-2.9.7.jar:/opt/landoop/kafka/share/java/kafka/javassist-3.22.0-CR2.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-b42.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.1.jar:/opt/landoop/kafka/share/java/kafka/jaxb-api-2.3.0.jar:/opt/landoop/kafka/share/java/kafka/jersey-client-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-common-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-container-servlet-core-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-hk2-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-media-jaxb-2.27.jar:/opt/landoop/kafka/share/java/kafka/jersey-server-2.27.jar:/opt/landoop/kafka/share/java/kafka/jetty-client-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-continuation-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-http-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-io-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-security-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-server-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlet-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-servlets-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jetty-util-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/kafka/jopt-simple-5.0.4.jar:/opt/landoop/kafka/share/java/kafka/kafka-clients-2.0.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-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-examples-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-scala_2.12-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-streams-test-utils-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka-tools-2.0.1-L0.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.0.1-L0-sources.jar:/opt/landoop/kafka/share/java/kafka/kafka_2.12-2.0.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.12.6.jar:/opt/landoop/kafka/share/java/kafka/scala-logging_2.12-3.9.0.jar:/opt/landoop/kafka/share/java/kafka/scala-reflect-2.12.6.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.13.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-5.0.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-connect-avro-converter-5.0.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-json-serializer-5.0.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-schema-registry-client-5.0.1.jar:/opt/landoop/kafka/share/java/kafka-serde-tools/kafka-streams-avro-serde-5.0.1.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/audience-annotations-0.5.0.jar:/opt/landoop/kafka/share/java/confluent-common/build-tools-5.0.1.jar:/opt/landoop/kafka/share/java/confluent-common/common-config-5.0.1.jar:/opt/landoop/kafka/share/java/confluent-common/common-metrics-5.0.1.jar:/opt/landoop/kafka/share/java/confluent-common/common-utils-5.0.1.jar:/opt/landoop/kafka/share/java/confluent-common/jline-0.9.94.jar:/opt/landoop/kafka/share/java/confluent-common/netty-3.10.6.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.13.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/asm-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-analysis-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-commons-6.2.jar:/opt/landoop/kafka/share/java/landoop-common/asm-tree-6.2.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/calcite-linq4j-1.8.0.jar:/opt/landoop/kafka/share/java/landoop-common/classmate-1.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-config-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-metrics-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/common-utils-5.0.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-2.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/connect-json-2.0.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/jackson-annotations-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-core-2.9.6.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.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-base-2.9.6.jar:/opt/landoop/kafka/share/java/landoop-common/jackson-jaxrs-json-provider-2.9.6.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.6.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-websocket-client-impl-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/javax-websocket-server-impl-9.4.11.v20180605.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.websocket-api-1.0.jar:/opt/landoop/kafka/share/java/landoop-common/javax.websocket-client-api-1.0.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.27.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-annotations-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jaas-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jmx-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-jndi-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-plus-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-webapp-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/jetty-xml-9.4.11.v20180605.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-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-clients-2.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-connect-avro-converter-5.0.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-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka-schema-registry-client-5.0.0.jar:/opt/landoop/kafka/share/java/landoop-common/kafka_2.11-2.0.0-cp1.jar:/opt/landoop/kafka/share/java/landoop-common/kcql-2.8.3.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.6.Final.jar:/opt/landoop/kafka/share/java/landoop-common/paranamer-2.8.jar:/opt/landoop/kafka/share/java/landoop-common/rest-utils-5.0.0.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/websocket-api-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-client-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-common-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-server-9.4.11.v20180605.jar:/opt/landoop/kafka/share/java/landoop-common/websocket-servlet-9.4.11.v20180605.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[2019-04-23 06:10:01,342] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone:76)\n[2019-04-23 06:10:01,371] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-couchbase (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:02,273] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-couchbase/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:02,274] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,274] INFO Added plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,308] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-dbvisitreplicate (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:02,336] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-dbvisitreplicate/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:02,336] INFO Added plugin 'com.dbvisit.replicate.kafkaconnect.ReplicateSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,338] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-mongodb (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:02,515] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-mongodb/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:02,515] INFO Added plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,515] INFO Added plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,516] INFO Added plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,516] INFO Added plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,518] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-mysql (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:02,819] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-mysql/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:02,819] INFO Added plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,827] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-debezium-postgres (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:02,924] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-debezium-postgres/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:02,924] INFO Added plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:02,933] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-elasticsearch (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:03,356] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-elasticsearch/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:03,357] INFO Added plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:03,358] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-hdfs (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:06,320] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-hdfs/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:06,320] INFO Added plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,320] INFO Added plugin 'io.confluent.connect.storage.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,320] INFO Added plugin 'io.confluent.connect.hdfs.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,320] INFO Added plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,321] INFO Added plugin 'org.apache.kafka.common.config.provider.FileConfigProvider' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,369] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-jdbc (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:06,543] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-jdbc/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:06,543] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,543] INFO Added plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:06,561] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-s3 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:08,716] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-s3/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:08,716] INFO Added plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:08,750] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-splunk (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:08,969] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-splunk/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:08,969] INFO Added plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:08,969] INFO Added plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:08,969] INFO Added plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:08,971] INFO Loading plugin from: /opt/landoop/connectors/third-party/kafka-connect-twitter (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:222)\n[2019-04-23 06:10:09,948] INFO Registered loader: PluginClassLoader{pluginLocation=file:/opt/landoop/connectors/third-party/kafka-connect-twitter/} (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:09,949] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:09,949] INFO Added plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,273] INFO Registered loader: sun.misc.Launcher$AppClassLoader@764c12b6 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:245)\n[2019-04-23 06:10:11,273] INFO Added plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,273] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,273] INFO Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,273] INFO Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,273] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,274] INFO Added plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.Flatten$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,275] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.ReplaceField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.ExtractField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.SetSchemaMetadata$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.MaskField$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,276] INFO Added plugin 'org.apache.kafka.connect.transforms.HoistField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,277] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,277] INFO Added plugin 'org.apache.kafka.connect.transforms.TimestampConverter$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,277] INFO Added plugin 'org.apache.kafka.connect.transforms.Cast$Key' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,277] INFO Added plugin 'org.apache.kafka.connect.transforms.InsertField$Value' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,277] INFO Added plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:174)\n[2019-04-23 06:10:11,279] INFO Added aliases 'CouchbaseSinkConnector' and 'CouchbaseSink' to plugin 'com.couchbase.connect.kafka.CouchbaseSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,279] INFO Added aliases 'CouchbaseSourceConnector' and 'CouchbaseSource' to plugin 'com.couchbase.connect.kafka.CouchbaseSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,280] INFO Added aliases 'ReplicateSourceConnector' and 'ReplicateSource' to plugin 'com.dbvisit.replicate.kafkaconnect.ReplicateSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,280] INFO Added aliases 'TwitterSinkConnector' and 'TwitterSink' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,280] INFO Added aliases 'TwitterSourceConnector' and 'TwitterSource' to plugin 'com.eneco.trading.kafka.connect.twitter.TwitterSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,280] INFO Added aliases 'SplunkSinkConnector' and 'SplunkSink' to plugin 'com.splunk.kafka.connect.SplunkSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,280] INFO Added aliases 'ElasticsearchSinkConnector' and 'ElasticsearchSink' to plugin 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,281] INFO Added aliases 'HdfsSinkConnector' and 'HdfsSink' to plugin 'io.confluent.connect.hdfs.HdfsSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,281] INFO Added aliases 'JdbcSinkConnector' and 'JdbcSink' to plugin 'io.confluent.connect.jdbc.JdbcSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,281] INFO Added aliases 'JdbcSourceConnector' and 'JdbcSource' to plugin 'io.confluent.connect.jdbc.JdbcSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,281] INFO Added aliases 'S3SinkConnector' and 'S3Sink' to plugin 'io.confluent.connect.s3.S3SinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,281] INFO Added aliases 'MongoDbConnector' and 'MongoDb' to plugin 'io.debezium.connector.mongodb.MongoDbConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'MySqlConnector' and 'MySql' to plugin 'io.debezium.connector.mysql.MySqlConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'PostgresConnector' and 'Postgres' to plugin 'io.debezium.connector.postgresql.PostgresConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'FileStreamSinkConnector' and 'FileStreamSink' to plugin 'org.apache.kafka.connect.file.FileStreamSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'FileStreamSourceConnector' and 'FileStreamSource' to plugin 'org.apache.kafka.connect.file.FileStreamSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'MockConnector' and 'Mock' to plugin 'org.apache.kafka.connect.tools.MockConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,282] INFO Added aliases 'MockSinkConnector' and 'MockSink' to plugin 'org.apache.kafka.connect.tools.MockSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'MockSourceConnector' and 'MockSource' to plugin 'org.apache.kafka.connect.tools.MockSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'VerifiableSinkConnector' and 'VerifiableSink' to plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'VerifiableSourceConnector' and 'VerifiableSource' to plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'AvroConverter' and 'Avro' to plugin 'io.confluent.connect.avro.AvroConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,283] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,284] INFO Added aliases 'ByteArrayConverter' and 'ByteArray' to plugin 'org.apache.kafka.connect.converters.ByteArrayConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'DoubleConverter' and 'Double' to plugin 'org.apache.kafka.connect.converters.DoubleConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'FloatConverter' and 'Float' to plugin 'org.apache.kafka.connect.converters.FloatConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'IntegerConverter' and 'Integer' to plugin 'org.apache.kafka.connect.converters.IntegerConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'LongConverter' and 'Long' to plugin 'org.apache.kafka.connect.converters.LongConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'ShortConverter' and 'Short' to plugin 'org.apache.kafka.connect.converters.ShortConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added aliases 'JsonConverter' and 'Json' to plugin 'org.apache.kafka.connect.json.JsonConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,285] INFO Added alias 'SimpleHeaderConverter' to plugin 'org.apache.kafka.connect.storage.SimpleHeaderConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,285] INFO Added aliases 'StringConverter' and 'String' to plugin 'org.apache.kafka.connect.storage.StringConverter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:396)\n[2019-04-23 06:10:11,286] INFO Added alias 'Transformation' to plugin 'com.landoop.connect.sql.Transformation' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,286] INFO Added alias 'UnwrapFromMongoDbEnvelope' to plugin 'io.debezium.connector.mongodb.transforms.UnwrapFromMongoDbEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,287] INFO Added alias 'ByLogicalTableRouter' to plugin 'io.debezium.transforms.ByLogicalTableRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,287] INFO Added alias 'UnwrapFromEnvelope' to plugin 'io.debezium.transforms.UnwrapFromEnvelope' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,288] INFO Added alias 'RegexRouter' to plugin 'org.apache.kafka.connect.transforms.RegexRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,289] INFO Added alias 'TimestampRouter' to plugin 'org.apache.kafka.connect.transforms.TimestampRouter' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,289] INFO Added alias 'ValueToKey' to plugin 'org.apache.kafka.connect.transforms.ValueToKey' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,289] INFO Added alias 'BasicAuthSecurityRestExtension' to plugin 'org.apache.kafka.connect.rest.basic.auth.extension.BasicAuthSecurityRestExtension' (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:393)\n[2019-04-23 06:10:11,305] INFO StandaloneConfig values: \n\taccess.control.allow.methods = \n\taccess.control.allow.origin = \n\tbootstrap.servers = [localhost:9092]\n\tconfig.providers = []\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.extension.classes = []\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[2019-04-23 06:10:11,305] INFO Worker configuration property 'internal.key.converter' is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:307)\n[2019-04-23 06:10:11,305] INFO Worker configuration property 'internal.key.converter.schemas.enable' (along with all configuration for 'internal.key.converter') is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:307)\n[2019-04-23 06:10:11,305] INFO Worker configuration property 'internal.value.converter' is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:307)\n[2019-04-23 06:10:11,305] INFO Worker configuration property 'internal.value.converter.schemas.enable' (along with all configuration for 'internal.value.converter') is deprecated and may be removed in an upcoming release. The specified value matches the default, so this property can be safely removed from the worker configuration. (org.apache.kafka.connect.runtime.WorkerConfig:307)\n[2019-04-23 06:10:11,307] INFO Creating Kafka admin client (org.apache.kafka.connect.util.ConnectUtils:43)\n[2019-04-23 06:10:11,313] 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.client.callback.handler.class = null\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.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\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 = https\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[2019-04-23 06:10:11,358] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'internal.key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'rest.port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'value.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'internal.key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'port' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'internal.value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'internal.value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,358] WARN The configuration 'key.converter.schema.registry.url' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig:287)\n[2019-04-23 06:10:11,359] INFO Kafka version : 2.0.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2019-04-23 06:10:11,359] INFO Kafka commitId : fa14705e51bd2ce5 (org.apache.kafka.common.utils.AppInfoParser:110)\n[2019-04-23 06:10:11,560] INFO Kafka cluster ID: AUiLb7i2Qiq_RnWvAc3uzQ (org.apache.kafka.connect.util.ConnectUtils:59)\n[2019-04-23 06:10:11,578] INFO Logging initialized @10807ms to org.eclipse.jetty.util.log.Slf4jLog (org.eclipse.jetty.util.log:193)\n[2019-04-23 06:10:11,632] INFO Added connector for http://:38783 (org.apache.kafka.connect.runtime.rest.RestServer:119)\n[2019-04-23 06:10:11,656] INFO Advertised URI: http://172.17.0.4:38783/ (org.apache.kafka.connect.runtime.rest.RestServer:267)\n[2019-04-23 06:10:11,664] INFO Kafka version : 2.0.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2019-04-23 06:10:11,664] INFO Kafka commitId : fa14705e51bd2ce5 (org.apache.kafka.common.utils.AppInfoParser:110)\n[2019-04-23 06:10:11,797] 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[2019-04-23 06:10:11,799] 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[2019-04-23 06:10:11,807] INFO Kafka Connect standalone worker initialization took 10489ms (org.apache.kafka.connect.cli.ConnectStandalone:92)\n[2019-04-23 06:10:11,807] INFO Kafka Connect starting (org.apache.kafka.connect.runtime.Connect:49)\n[2019-04-23 06:10:11,807] INFO Herder starting (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:88)\n[2019-04-23 06:10:11,807] INFO Worker starting (org.apache.kafka.connect.runtime.Worker:172)\n[2019-04-23 06:10:11,807] INFO Starting FileOffsetBackingStore with file coyote_connect.offset (org.apache.kafka.connect.storage.FileOffsetBackingStore:59)\n[2019-04-23 06:10:11,810] INFO Worker started (org.apache.kafka.connect.runtime.Worker:177)\n[2019-04-23 06:10:11,810] INFO Herder started (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:90)\n[2019-04-23 06:10:11,810] INFO Starting REST server (org.apache.kafka.connect.runtime.rest.RestServer:163)\n[2019-04-23 06:10:11,915] INFO jetty-9.4.11.v20180605; built: 2018-06-05T18:24:03.829Z; git: d5fc0523cfa96bfebfbda19606cad384d772f04c; jvm 1.8.0_201-b08 (org.eclipse.jetty.server.Server:374)\n[2019-04-23 06:10:11,951] INFO DefaultSessionIdManager workerName=node0 (org.eclipse.jetty.server.session:365)\n[2019-04-23 06:10:11,951] INFO No SessionScavenger set, using defaults (org.eclipse.jetty.server.session:370)\n[2019-04-23 06:10:11,953] INFO node0 Scavenging every 660000ms (org.eclipse.jetty.server.session:149)\n[2019-04-23 06:10:12,506] INFO HV000001: Hibernate Validator 5.1.3.Final (org.hibernate.validator.internal.util.Version:27)\n[2019-04-23 06:10:12,628] INFO Started o.e.j.s.ServletContextHandler@642857e0{/,null,AVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:851)\n[2019-04-23 06:10:12,638] INFO Started http_38783@3ff54f3d{HTTP/1.1,[http/1.1]}{0.0.0.0:38783} (org.eclipse.jetty.server.AbstractConnector:289)\n[2019-04-23 06:10:12,638] INFO Started @11868ms (org.eclipse.jetty.server.Server:411)\n[2019-04-23 06:10:12,638] INFO Advertised URI: http://172.17.0.4:38783/ (org.apache.kafka.connect.runtime.rest.RestServer:267)\n[2019-04-23 06:10:12,639] 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:217)\n[2019-04-23 06:10:12,639] INFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:55)\n[2019-04-23 06:10:12,677] INFO AbstractConfig values: \n\tbatch.max.rows = 100\n\tcatalog.pattern = null\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\tdialect.name = \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 (org.apache.kafka.common.config.AbstractConfig:279)\n[2019-04-23 06:10:12,787] INFO ConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig:279)\n[2019-04-23 06:10:12,787] INFO EnrichedConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2019-04-23 06:10:12,787] INFO Creating connector coyote-ca-1555999799933 of type io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:235)\n[2019-04-23 06:10:12,791] INFO Instantiated connector coyote-ca-1555999799933 with version 5.0.1 of type class io.confluent.connect.jdbc.JdbcSourceConnector (org.apache.kafka.connect.runtime.Worker:238)\n[2019-04-23 06:10:12,791] INFO Starting JDBC Source Connector (io.confluent.connect.jdbc.JdbcSourceConnector:70)\n[2019-04-23 06:10:12,792] INFO JdbcSourceConnectorConfig values: \n\tbatch.max.rows = 100\n\tcatalog.pattern = null\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\tdialect.name = \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[2019-04-23 06:10:12,792] INFO Attempting to open connection #1 to Sqlite (io.confluent.connect.jdbc.util.CachedConnectionProvider:88)\n[2019-04-23 06:10:12,795] INFO Starting thread to monitor tables. (io.confluent.connect.jdbc.source.TableMonitorThread:74)\n[2019-04-23 06:10:12,796] INFO Finished creating connector coyote-ca-1555999799933 (org.apache.kafka.connect.runtime.Worker:257)\n[2019-04-23 06:10:12,801] INFO SourceConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.SourceConnectorConfig:279)\n[2019-04-23 06:10:12,801] INFO EnrichedConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2019-04-23 06:10:12,810] INFO After filtering the tables are: \"accounts\" (io.confluent.connect.jdbc.source.TableMonitorThread:178)\n[2019-04-23 06:10:12,814] INFO Creating task coyote-ca-1555999799933-0 (org.apache.kafka.connect.runtime.Worker:396)\n[2019-04-23 06:10:12,815] INFO ConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig:279)\n[2019-04-23 06:10:12,815] INFO EnrichedConnectorConfig values: \n\tconfig.action.reload = RESTART\n\tconnector.class = io.confluent.connect.jdbc.JdbcSourceConnector\n\terrors.log.enable = false\n\terrors.log.include.messages = false\n\terrors.retry.delay.max.ms = 60000\n\terrors.retry.timeout = 0\n\terrors.tolerance = none\n\theader.converter = null\n\tkey.converter = null\n\tname = coyote-ca-1555999799933\n\ttasks.max = 1\n\ttransforms = []\n\tvalue.converter = null\n (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:279)\n[2019-04-23 06:10:12,816] INFO TaskConfig values: \n\ttask.class = class io.confluent.connect.jdbc.source.JdbcSourceTask\n (org.apache.kafka.connect.runtime.TaskConfig:279)\n[2019-04-23 06:10:12,817] INFO Instantiated task coyote-ca-1555999799933-0 with version 5.0.1 of type io.confluent.connect.jdbc.source.JdbcSourceTask (org.apache.kafka.connect.runtime.Worker:411)\n[2019-04-23 06:10:12,822] INFO AvroConverterConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:12,832] INFO KafkaAvroSerializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:12,836] INFO KafkaAvroDeserializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:13,011] 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[2019-04-23 06:10:13,012] INFO Set up the key converter class io.confluent.connect.avro.AvroConverter for task coyote-ca-1555999799933-0 using the worker config (org.apache.kafka.connect.runtime.Worker:434)\n[2019-04-23 06:10:13,012] INFO AvroConverterConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:13,012] INFO KafkaAvroSerializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:13,012] INFO KafkaAvroDeserializerConfig values: \n\tschema.registry.url = [http://localhost:8081]\n\tbasic.auth.user.info = [hidden]\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[2019-04-23 06:10:13,012] 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[2019-04-23 06:10:13,012] INFO Set up the value converter class io.confluent.connect.avro.AvroConverter for task coyote-ca-1555999799933-0 using the worker config (org.apache.kafka.connect.runtime.Worker:440)\n[2019-04-23 06:10:13,013] INFO Set up the header converter class org.apache.kafka.connect.storage.SimpleHeaderConverter for task coyote-ca-1555999799933-0 using the worker config (org.apache.kafka.connect.runtime.Worker:446)\n[2019-04-23 06:10:13,025] 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.client.callback.handler.class = null\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.login.callback.handler.class = null\n\tsasl.login.class = null\n\tsasl.login.refresh.buffer.seconds = 300\n\tsasl.login.refresh.min.period.seconds = 60\n\tsasl.login.refresh.window.factor = 0.8\n\tsasl.login.refresh.window.jitter = 0.05\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 = https\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[2019-04-23 06:10:13,058] INFO Kafka version : 2.0.1-L0 (org.apache.kafka.common.utils.AppInfoParser:109)\n[2019-04-23 06:10:13,058] INFO Kafka commitId : fa14705e51bd2ce5 (org.apache.kafka.common.utils.AppInfoParser:110)\n[2019-04-23 06:10:13,069] INFO Starting JDBC source task (io.confluent.connect.jdbc.source.JdbcSourceTask:80)\n[2019-04-23 06:10:13,069] INFO Created connector coyote-ca-1555999799933 (org.apache.kafka.connect.cli.ConnectStandalone:104)\n[2019-04-23 06:10:13,071] INFO JdbcSourceTaskConfig values: \n\tbatch.max.rows = 100\n\tcatalog.pattern = null\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\tdialect.name = \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[2019-04-23 06:10:13,072] INFO Using JDBC dialect Sqlite (io.confluent.connect.jdbc.source.JdbcSourceTask:97)\n[2019-04-23 06:10:13,104] INFO Attempting to open connection #1 to Sqlite (io.confluent.connect.jdbc.util.CachedConnectionProvider:88)\n[2019-04-23 06:10:13,114] INFO Started JDBC source task (io.confluent.connect.jdbc.source.JdbcSourceTask:241)\n[2019-04-23 06:10:13,114] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Source task finished initialization and start (org.apache.kafka.connect.runtime.WorkerSourceTask:199)\n[2019-04-23 06:10:13,116] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:13,354] WARN [Producer clientId=producer-1] Error while fetching metadata with correlation id 1 : {coyote-ca-accounts=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:968)\n[2019-04-23 06:10:13,355] INFO Cluster ID: AUiLb7i2Qiq_RnWvAc3uzQ (org.apache.kafka.clients.Metadata:285)\n[2019-04-23 06:10:18,068] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:18,069] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:18,083] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Finished commitOffsets successfully in 14 ms (org.apache.kafka.connect.runtime.WorkerSourceTask:496)\n[2019-04-23 06:10:18,125] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:23,083] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:23,084] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:23,126] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:28,084] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:28,085] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:28,127] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:33,085] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:33,086] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:33,129] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:38,087] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:38,087] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:38,130] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:43,088] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:43,088] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:43,131] INFO TimestampIncrementingTableQuerier{table=\"accounts\", query='null', topicPrefix='coyote-ca-', incrementingColumn='id', timestampColumns=[]} prepared SQL query: SELECT * FROM \"accounts\" WHERE \"accounts\".\"id\" > ? ORDER BY \"accounts\".\"id\" ASC (io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier:161)\n[2019-04-23 06:10:44,944] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:65)\n[2019-04-23 06:10:44,946] INFO Stopping REST server (org.apache.kafka.connect.runtime.rest.RestServer:223)\n[2019-04-23 06:10:44,960] INFO Stopped http_38783@3ff54f3d{HTTP/1.1,[http/1.1]}{0.0.0.0:38783} (org.eclipse.jetty.server.AbstractConnector:332)\n[2019-04-23 06:10:44,961] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:167)\n[2019-04-23 06:10:44,996] INFO Stopped o.e.j.s.ServletContextHandler@642857e0{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:1020)\n[2019-04-23 06:10:45,000] INFO REST server stopped (org.apache.kafka.connect.runtime.rest.RestServer:241)\n[2019-04-23 06:10:45,001] INFO Herder stopping (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:95)\n[2019-04-23 06:10:45,002] INFO Stopping task coyote-ca-1555999799933-0 (org.apache.kafka.connect.runtime.Worker:555)\n[2019-04-23 06:10:45,003] INFO Stopping JDBC source task (io.confluent.connect.jdbc.source.JdbcSourceTask:256)\n[2019-04-23 06:10:48,132] INFO Closing resources for JDBC source task (io.confluent.connect.jdbc.source.JdbcSourceTask:263)\n[2019-04-23 06:10:48,133] INFO Closing connection #1 to Sqlite (io.confluent.connect.jdbc.util.CachedConnectionProvider:114)\n[2019-04-23 06:10:48,134] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:397)\n[2019-04-23 06:10:48,134] INFO WorkerSourceTask{id=coyote-ca-1555999799933-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:414)\n[2019-04-23 06:10:48,134] INFO [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1090)\n[2019-04-23 06:10:48,144] INFO Stopping connector coyote-ca-1555999799933 (org.apache.kafka.connect.runtime.Worker:338)\n[2019-04-23 06:10:48,145] INFO Stopping table monitoring thread (io.confluent.connect.jdbc.JdbcSourceConnector:166)\n[2019-04-23 06:10:48,145] INFO Shutting down thread monitoring tables. (io.confluent.connect.jdbc.source.TableMonitorThread:135)\n[2019-04-23 06:10:48,147] INFO Closing connection #1 to Sqlite (io.confluent.connect.jdbc.util.CachedConnectionProvider:114)\n[2019-04-23 06:10:48,149] INFO Stopped connector coyote-ca-1555999799933 (org.apache.kafka.connect.runtime.Worker:354)\n[2019-04-23 06:10:48,149] INFO Worker stopping (org.apache.kafka.connect.runtime.Worker:184)\n[2019-04-23 06:10:48,150] INFO Stopped FileOffsetBackingStore (org.apache.kafka.connect.storage.FileOffsetBackingStore:67)\n[2019-04-23 06:10:48,151] INFO Worker stopped (org.apache.kafka.connect.runtime.Worker:205)\n[2019-04-23 06:10:48,152] INFO Herder stopped (org.apache.kafka.connect.runtime.standalone.StandaloneHerder:112)\n[2019-04-23 06:10:48,153] INFO Kafka Connect stopped (org.apache.kafka.connect.runtime.Connect:70)\n"
2019/04/23 06:10:51 Success, command 'timeout 10
kafka-console-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\t\x02\x02\nalice\n\x00\x00\x00\x00\t\x04\x02\x06bob\n"
2019/04/23 06:10:53 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"
2019/04/23 06:10:53 Success, command 'rm -rf coyote_test.sqlite coyote_sqlite_connector.properties coyote_connect_standalone.properties coyote_connect.offset', test ''. Stdout: ""
2019/04/23 06:10:53 no errors