18:21:16,109 main ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = latest bootstrap.servers = [localhost:9092] check.crcs = true client.id = connections.max.idle.ms = 540000 enable.auto.commit = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = test12345 heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 1000 request.timeout.ms = 305000 retry.backoff.ms = 1000 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 18:21:16,111 main Starting the Kafka consumer 18:21:16,119 main ConsumerConfig values: auto.commit.interval.ms = 5000 auto.offset.reset = latest bootstrap.servers = [localhost:9092] check.crcs = true client.id = consumer-1 connections.max.idle.ms = 540000 enable.auto.commit = true exclude.internal.topics = true fetch.max.bytes = 52428800 fetch.max.wait.ms = 500 fetch.min.bytes = 1 group.id = test12345 heartbeat.interval.ms = 3000 interceptor.classes = null key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer max.partition.fetch.bytes = 1048576 max.poll.interval.ms = 300000 max.poll.records = 500 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.sample.window.ms = 30000 partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] receive.buffer.bytes = 65536 reconnect.backoff.ms = 1000 request.timeout.ms = 305000 retry.backoff.ms = 1000 sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 session.timeout.ms = 10000 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 18:21:16,128 main Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = []) 18:21:16,137 main Added sensor with name connections-closed: 18:21:16,138 main Added sensor with name connections-created: 18:21:16,138 main Added sensor with name bytes-sent-received: 18:21:16,139 main Added sensor with name bytes-sent: 18:21:16,140 main Added sensor with name bytes-received: 18:21:16,140 main Added sensor with name select-time: 18:21:16,141 main Added sensor with name io-time: 18:21:16,154 main Added sensor with name heartbeat-latency 18:21:16,155 main Added sensor with name join-latency 18:21:16,155 main Added sensor with name sync-latency 18:21:16,157 main Added sensor with name commit-latency 18:21:16,168 main Added sensor with name bytes-fetched 18:21:16,169 main Added sensor with name records-fetched 18:21:16,169 main Added sensor with name fetch-latency 18:21:16,169 main Added sensor with name records-lag 18:21:16,170 main Added sensor with name fetch-throttle-time 18:21:16,172 main Kafka version : 0.10.1.0 18:21:16,173 main Kafka commitId : 3402a74efb23d1d4 18:21:16,173 main Kafka consumer created 18:21:16,189 main Initiating connection to node -1 at localhost:9092. 18:21:16,239 main Added sensor with name node--1.bytes-sent 18:21:16,239 main Added sensor with name node--1.bytes-received 18:21:16,239 main Added sensor with name node--1.latency 18:21:16,240 main Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1 18:21:16,240 main Completed connection to node -1 18:21:17,191 main Sending metadata request {topics=[]} to node -1 18:21:17,202 main Updated cluster metadata version 2 to Cluster(id = 8Bs2KyogRH2fJy-HRD65fw, nodes = [localhost:9092 (id: 0 rack: null)], partitions = []) 18:21:17,205 main Subscribed to partition(s): test-topic-0 18:21:17,206 main Sending coordinator request for group test12345 to broker localhost:9092 (id: 0 rack: null) 18:21:17,207 main Initiating connection to node 0 at localhost:9092. 18:21:17,207 main Added sensor with name node-0.bytes-sent 18:21:17,207 main Added sensor with name node-0.bytes-received 18:21:17,208 main Added sensor with name node-0.latency 18:21:17,208 main Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0 18:21:17,208 main Completed connection to node 0 18:21:17,210 main Received group coordinator response ClientResponse(receivedTimeMs=1495034477210, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@45efd90f, request=RequestSend(header={api_key=10,api_version=0,correlation_id=2,client_id=consumer-1}, body={group_id=test12345}), createdTimeMs=1495034477206, sendTimeMs=1495034477208), responseBody={error_code=0,coordinator={node_id=0,host=localhost,port=9092}}) 18:21:17,210 main Discovered coordinator localhost:9092 (id: 2147483647 rack: null) for group test12345. 18:21:17,210 main Initiating connection to node 2147483647 at localhost:9092. 18:21:17,211 main Group test12345 fetching committed offsets for partitions: [test-topic-0] 18:21:17,212 main Added sensor with name node-2147483647.bytes-sent 18:21:17,213 main Added sensor with name node-2147483647.bytes-received 18:21:17,213 main Added sensor with name node-2147483647.latency 18:21:17,213 main Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483647 18:21:17,213 main Completed connection to node 2147483647 18:21:17,215 main Resetting offset for partition test-topic-0 to the committed offset 0 18:21:18,195 main Sending metadata request {topics=[test-topic]} to node 0 18:21:18,197 main Updated cluster metadata version 3 to Cluster(id = 8Bs2KyogRH2fJy-HRD65fw, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test-topic, partition = 0, leader = 0, replicas = [0,], isr = [0,])]) 18:21:18,213 main Group test12345 committed offset 0 for partition test-topic-0 18:21:18,213 main Completed autocommit of offsets {test-topic-0=OffsetAndMetadata{offset=0, metadata=''}} for group test12345 18:21:18,709 main Added sensor with name topic.test-topic.bytes-fetched 18:21:18,709 main Added sensor with name topic.test-topic.records-fetched 18:21:20,619 main Connection with localhost/127.0.0.1 disconnected java.io.EOFException at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.poll(Selector.java:291) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1031) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) [kafka-clients-0.10.1.0.jar:?] at com.openwaygroup.io.test.KafkaTestDemoApp.main(KafkaTestDemoApp.java:35) [bin/:?] 18:21:20,623 main Node 2147483647 disconnected. 18:21:20,624 main Marking the coordinator localhost:9092 (id: 2147483647 rack: null) dead for group test12345 18:21:20,624 main Sending metadata request {topics=[test-topic]} to node 0 18:21:20,625 main Connection with localhost/127.0.0.1 disconnected java.io.EOFException at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.poll(Selector.java:291) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1031) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) [kafka-clients-0.10.1.0.jar:?] at com.openwaygroup.io.test.KafkaTestDemoApp.main(KafkaTestDemoApp.java:35) [bin/:?] 18:21:20,625 main Connection with localhost/127.0.0.1 disconnected java.io.EOFException at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:83) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:71) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:154) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:135) ~[kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:343) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.common.network.Selector.poll(Selector.java:291) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1031) [kafka-clients-0.10.1.0.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) [kafka-clients-0.10.1.0.jar:?] at com.openwaygroup.io.test.KafkaTestDemoApp.main(KafkaTestDemoApp.java:35) [bin/:?] 18:21:20,626 main Node 0 disconnected. 18:21:20,626 main Node -1 disconnected. 18:21:20,626 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2415fc55, request=RequestSend(header={api_key=1,api_version=3,correlation_id=10,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480215, sendTimeMs=1495034480215) with correlation id 10 due to node 0 being disconnected 18:21:20,628 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,628 main Give up sending metadata request since no node is available 18:21:20,628 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@13bc8645, request=RequestSend(header={api_key=1,api_version=3,correlation_id=12,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480628, sendTimeMs=0) with correlation id 12 due to node 0 being disconnected 18:21:20,629 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,629 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@24c22fe, request=RequestSend(header={api_key=1,api_version=3,correlation_id=13,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480629, sendTimeMs=0) with correlation id 13 due to node 0 being disconnected 18:21:20,629 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,632 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@93081b6, request=RequestSend(header={api_key=1,api_version=3,correlation_id=14,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480629, sendTimeMs=0) with correlation id 14 due to node 0 being disconnected 18:21:20,632 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,632 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@cd1e646, request=RequestSend(header={api_key=1,api_version=3,correlation_id=15,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480632, sendTimeMs=0) with correlation id 15 due to node 0 being disconnected 18:21:20,632 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,633 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7ba8c737, request=RequestSend(header={api_key=1,api_version=3,correlation_id=16,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480633, sendTimeMs=0) with correlation id 16 due to node 0 being disconnected 18:21:20,633 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,633 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@1890516e, request=RequestSend(header={api_key=1,api_version=3,correlation_id=17,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480633, sendTimeMs=0) with correlation id 17 due to node 0 being disconnected 18:21:20,634 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,634 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@15a04efb, request=RequestSend(header={api_key=1,api_version=3,correlation_id=18,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480634, sendTimeMs=0) with correlation id 18 due to node 0 being disconnected 18:21:20,634 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,635 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@16c069df, request=RequestSend(header={api_key=1,api_version=3,correlation_id=19,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480634, sendTimeMs=0) with correlation id 19 due to node 0 being disconnected 18:21:20,635 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,635 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2bec854f, request=RequestSend(header={api_key=1,api_version=3,correlation_id=20,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480635, sendTimeMs=0) with correlation id 20 due to node 0 being disconnected 18:21:20,636 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,636 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@31edaa7d, request=RequestSend(header={api_key=1,api_version=3,correlation_id=21,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480636, sendTimeMs=0) with correlation id 21 due to node 0 being disconnected 18:21:20,636 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,637 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@26adfd2d, request=RequestSend(header={api_key=1,api_version=3,correlation_id=22,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480636, sendTimeMs=0) with correlation id 22 due to node 0 being disconnected 18:21:20,637 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,637 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@3336e6b6, request=RequestSend(header={api_key=1,api_version=3,correlation_id=23,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480637, sendTimeMs=0) with correlation id 23 due to node 0 being disconnected 18:21:20,637 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,638 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7c3fdb62, request=RequestSend(header={api_key=1,api_version=3,correlation_id=24,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480638, sendTimeMs=0) with correlation id 24 due to node 0 being disconnected 18:21:20,638 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,638 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@205d38da, request=RequestSend(header={api_key=1,api_version=3,correlation_id=25,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480638, sendTimeMs=0) with correlation id 25 due to node 0 being disconnected 18:21:20,639 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,639 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6950ed69, request=RequestSend(header={api_key=1,api_version=3,correlation_id=26,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480639, sendTimeMs=0) with correlation id 26 due to node 0 being disconnected 18:21:20,639 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,639 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6dd7b5a3, request=RequestSend(header={api_key=1,api_version=3,correlation_id=27,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480639, sendTimeMs=0) with correlation id 27 due to node 0 being disconnected 18:21:20,640 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,640 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6f3187b0, request=RequestSend(header={api_key=1,api_version=3,correlation_id=28,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480640, sendTimeMs=0) with correlation id 28 due to node 0 being disconnected 18:21:20,640 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,641 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2663e964, request=RequestSend(header={api_key=1,api_version=3,correlation_id=29,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480640, sendTimeMs=0) with correlation id 29 due to node 0 being disconnected 18:21:20,641 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,641 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@48b67364, request=RequestSend(header={api_key=1,api_version=3,correlation_id=30,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480641, sendTimeMs=0) with correlation id 30 due to node 0 being disconnected 18:21:20,641 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,642 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@189cbd7c, request=RequestSend(header={api_key=1,api_version=3,correlation_id=31,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480641, sendTimeMs=0) with correlation id 31 due to node 0 being disconnected 18:21:20,642 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,642 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7bf3a5d8, request=RequestSend(header={api_key=1,api_version=3,correlation_id=32,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480642, sendTimeMs=0) with correlation id 32 due to node 0 being disconnected 18:21:20,642 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,642 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@42e25b0b, request=RequestSend(header={api_key=1,api_version=3,correlation_id=33,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480642, sendTimeMs=0) with correlation id 33 due to node 0 being disconnected 18:21:20,643 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,643 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@39b43d60, request=RequestSend(header={api_key=1,api_version=3,correlation_id=34,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480643, sendTimeMs=0) with correlation id 34 due to node 0 being disconnected 18:21:20,643 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,643 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@44be0077, request=RequestSend(header={api_key=1,api_version=3,correlation_id=35,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480643, sendTimeMs=0) with correlation id 35 due to node 0 being disconnected 18:21:20,643 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,644 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2205a05d, request=RequestSend(header={api_key=1,api_version=3,correlation_id=36,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480644, sendTimeMs=0) with correlation id 36 due to node 0 being disconnected 18:21:20,644 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,644 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@72ef8d15, request=RequestSend(header={api_key=1,api_version=3,correlation_id=37,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480644, sendTimeMs=0) with correlation id 37 due to node 0 being disconnected 18:21:20,644 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,645 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@6aa8e115, request=RequestSend(header={api_key=1,api_version=3,correlation_id=38,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480645, sendTimeMs=0) with correlation id 38 due to node 0 being disconnected 18:21:20,645 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,645 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5e21e98f, request=RequestSend(header={api_key=1,api_version=3,correlation_id=39,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480645, sendTimeMs=0) with correlation id 39 due to node 0 being disconnected 18:21:20,645 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,646 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@51a9ad5e, request=RequestSend(header={api_key=1,api_version=3,correlation_id=40,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480646, sendTimeMs=0) with correlation id 40 due to node 0 being disconnected 18:21:20,646 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,646 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@5f20155b, request=RequestSend(header={api_key=1,api_version=3,correlation_id=41,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480646, sendTimeMs=0) with correlation id 41 due to node 0 being disconnected 18:21:20,646 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,647 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@72ade7e3, request=RequestSend(header={api_key=1,api_version=3,correlation_id=42,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480647, sendTimeMs=0) with correlation id 42 due to node 0 being disconnected 18:21:20,647 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,647 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@239105a8, request=RequestSend(header={api_key=1,api_version=3,correlation_id=43,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480647, sendTimeMs=0) with correlation id 43 due to node 0 being disconnected 18:21:20,648 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,648 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@3fce8fd9, request=RequestSend(header={api_key=1,api_version=3,correlation_id=44,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480648, sendTimeMs=0) with correlation id 44 due to node 0 being disconnected 18:21:20,648 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,648 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@609bcfb6, request=RequestSend(header={api_key=1,api_version=3,correlation_id=45,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480648, sendTimeMs=0) with correlation id 45 due to node 0 being disconnected 18:21:20,649 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,649 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@7d94beb9, request=RequestSend(header={api_key=1,api_version=3,correlation_id=46,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480649, sendTimeMs=0) with correlation id 46 due to node 0 being disconnected 18:21:20,649 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,650 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@560348e6, request=RequestSend(header={api_key=1,api_version=3,correlation_id=47,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480649, sendTimeMs=0) with correlation id 47 due to node 0 being disconnected 18:21:20,650 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,650 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@1df8b5b8, request=RequestSend(header={api_key=1,api_version=3,correlation_id=48,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480650, sendTimeMs=0) with correlation id 48 due to node 0 being disconnected 18:21:20,650 main Fetch request to localhost:9092 (id: 0 rack: null) failed org.apache.kafka.common.errors.DisconnectException 18:21:20,650 main Cancelled FETCH request ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@23202fce, request=RequestSend(header={api_key=1,api_version=3,correlation_id=49,client_id=consumer-1}, body={replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,topics=[{topic=test-topic,partitions=[{partition=0,fetch_offset=0,max_bytes=1048576}]}]}), createdTimeMs=1495034480650, sendTimeMs=0) with correlation id 49 due to node 0 being disconnected 18:21:20,650 main Fetch request to localhost:9092 (id: 0 rack: null) failed