API tools faq
paste
m5001

consumer1

m5001
Nov 3rd, 2017
67
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 123.64 KB | None | 0 0
raw download clone embed print report
  1. 2017-11-03 19:44:51 INFO KafkaConsumer - Start of topic worker. topic=test, numberOfProcessors=10
  2. 2017-11-03 19:44:51 INFO ConsumerConfig - ConsumerConfig values:
  3. auto.commit.interval.ms = 5000
  4. auto.offset.reset = earliest
  5. bootstrap.servers = [localhost:9092]
  6. check.crcs = true
  7. client.id =
  8. connections.max.idle.ms = 540000
  9. enable.auto.commit = false
  10. exclude.internal.topics = true
  11. fetch.max.bytes = 52428800
  12. fetch.max.wait.ms = 500
  13. fetch.min.bytes = 1
  14. group.id = testgroup
  15. heartbeat.interval.ms = 3000
  16. interceptor.classes = null
  17. internal.leave.group.on.close = true
  18. isolation.level = read_uncommitted
  19. key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  20. max.partition.fetch.bytes = 1048576
  21. max.poll.interval.ms = 300000
  22. max.poll.records = 500
  23. metadata.max.age.ms = 300000
  24. metric.reporters = []
  25. metrics.num.samples = 2
  26. metrics.recording.level = INFO
  27. metrics.sample.window.ms = 30000
  28. partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
  29. receive.buffer.bytes = 65536
  30. reconnect.backoff.max.ms = 1000
  31. reconnect.backoff.ms = 50
  32. request.timeout.ms = 305000
  33. retry.backoff.ms = 100
  34. sasl.jaas.config = null
  35. sasl.kerberos.kinit.cmd = /usr/bin/kinit
  36. sasl.kerberos.min.time.before.relogin = 60000
  37. sasl.kerberos.service.name = null
  38. sasl.kerberos.ticket.renew.jitter = 0.05
  39. sasl.kerberos.ticket.renew.window.factor = 0.8
  40. sasl.mechanism = GSSAPI
  41. security.protocol = PLAINTEXT
  42. send.buffer.bytes = 131072
  43. session.timeout.ms = 10000
  44. ssl.cipher.suites = null
  45. ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
  46. ssl.endpoint.identification.algorithm = null
  47. ssl.key.password = null
  48. ssl.keymanager.algorithm = SunX509
  49. ssl.keystore.location = null
  50. ssl.keystore.password = null
  51. ssl.keystore.type = JKS
  52. ssl.protocol = TLS
  53. ssl.provider = null
  54. ssl.secure.random.implementation = null
  55. ssl.trustmanager.algorithm = PKIX
  56. ssl.truststore.location = null
  57. ssl.truststore.password = null
  58. ssl.truststore.type = JKS
  59. value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
  60.  
  61. 2017-11-03 19:44:51 DEBUG KafkaConsumer - Starting the Kafka consumer
  62. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 1 to Cluster(id = null, nodes = [localhost:9092 (id: -1 rack: null)], partitions = [])
  63. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name fetch-throttle-time
  64. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name connections-closed:
  65. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name connections-created:
  66. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name bytes-sent-received:
  67. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name bytes-sent:
  68. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name bytes-received:
  69. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name select-time:
  70. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name io-time:
  71. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name heartbeat-latency
  72. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name join-latency
  73. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name sync-latency
  74. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name commit-latency
  75. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name bytes-fetched
  76. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name records-fetched
  77. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name fetch-latency
  78. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name records-lag
  79. 2017-11-03 19:44:52 WARN ConsumerConfig - The configuration 'schema.registry.url' was supplied but isn't a known config.
  80. 2017-11-03 19:44:52 INFO AppInfoParser - Kafka version : 0.11.0.0
  81. 2017-11-03 19:44:52 INFO AppInfoParser - Kafka commitId : cb8625948210849f
  82. 2017-11-03 19:44:52 DEBUG KafkaConsumer - Kafka consumer created
  83. 2017-11-03 19:44:52 INFO BufferedConsumerClientAdapterImpl - Subscribing to topic=test
  84. 2017-11-03 19:44:52 DEBUG KafkaConsumer - Subscribed to topic(s): test
  85. 2017-11-03 19:44:52 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  86. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: -1 rack: null)
  87. 2017-11-03 19:44:52 DEBUG NetworkClient - Initiating connection to node -1 at localhost:9092.
  88. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node--1.bytes-sent
  89. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node--1.bytes-received
  90. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node--1.latency
  91. 2017-11-03 19:44:52 DEBUG Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node -1
  92. 2017-11-03 19:44:52 DEBUG NetworkClient - Completed connection to node -1. Fetching API versions.
  93. 2017-11-03 19:44:52 DEBUG NetworkClient - Initiating API versions fetch from node -1.
  94. 2017-11-03 19:44:52 DEBUG NetworkClient - Recorded API versions for node -1: (Produce(0): 0 to 3 [usable: 3], Fetch(1): 0 to 5 [usable: 5], Offsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 4 [usable: 4], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0])
  95. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node -1
  96. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 2 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  97. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492281, latencyMs=164, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=0,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  98. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  99. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  100. 2017-11-03 19:44:52 DEBUG NetworkClient - Initialize connection to node 0 for sending metadata request
  101. 2017-11-03 19:44:52 DEBUG NetworkClient - Initiating connection to node 0 at localhost:9092.
  102. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node-0.bytes-sent
  103. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node-0.bytes-received
  104. 2017-11-03 19:44:52 DEBUG Metrics - Added sensor with name node-0.latency
  105. 2017-11-03 19:44:52 DEBUG Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 0
  106. 2017-11-03 19:44:52 DEBUG NetworkClient - Completed connection to node 0. Fetching API versions.
  107. 2017-11-03 19:44:52 DEBUG NetworkClient - Initiating API versions fetch from node 0.
  108. 2017-11-03 19:44:52 DEBUG NetworkClient - Recorded API versions for node 0: (Produce(0): 0 to 3 [usable: 3], Fetch(1): 0 to 5 [usable: 5], Offsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 4 [usable: 4], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0])
  109. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  110. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 3 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  111. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  112. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492392, latencyMs=13, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=5,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  113. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  114. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  115. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  116. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 4 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  117. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  118. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492493, latencyMs=6, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=7,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  119. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  120. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  121. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  122. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 5 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  123. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  124. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492598, latencyMs=6, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=9,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  125. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  126. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  127. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  128. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 6 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  129. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  130. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492702, latencyMs=7, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=11,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  131. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  132. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  133. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  134. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 7 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  135. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  136. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492806, latencyMs=7, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=13,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  137. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  138. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  139. 2017-11-03 19:44:52 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  140. 2017-11-03 19:44:52 DEBUG Metadata - Updated cluster metadata version 8 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  141. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  142. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763492922, latencyMs=17, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=15,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=COORDINATOR_NOT_AVAILABLE, node=:-1 (id: -1 rack: null))) for group testgroup
  143. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Group coordinator lookup for group testgroup failed: The coordinator is not available.
  144. 2017-11-03 19:44:52 DEBUG AbstractCoordinator - Coordinator discovery failed for group testgroup, refreshing metadata
  145. 2017-11-03 19:44:53 DEBUG NetworkClient - Sending metadata request (type=MetadataRequest, topics=test) to node 0
  146. 2017-11-03 19:44:53 DEBUG Metadata - Updated cluster metadata version 9 to Cluster(id = VTIDuXW7QVmxQcelayfOLg, nodes = [localhost:9092 (id: 0 rack: null)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 1, leader = 0, replicas = [0], isr = [0]), Partition(topic = test, partition = 2, leader = 0, replicas = [0], isr = [0])])
  147. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Sending GroupCoordinator request for group testgroup to broker localhost:9092 (id: 0 rack: null)
  148. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Received GroupCoordinator response ClientResponse(receivedTimeMs=1509763493011, latencyMs=3, disconnected=false, requestHeader={api_key=10,api_version=1,correlation_id=17,client_id=consumer-1}, responseBody=FindCoordinatorResponse(throttleTimeMs=0, errorMessage='null', error=NONE, node=localhost:9092 (id: 0 rack: null))) for group testgroup
  149. 2017-11-03 19:44:53 INFO AbstractCoordinator - Discovered coordinator localhost:9092 (id: 2147483647 rack: null) for group testgroup.
  150. 2017-11-03 19:44:53 DEBUG NetworkClient - Initiating connection to node 2147483647 at localhost:9092.
  151. 2017-11-03 19:44:53 INFO ConsumerCoordinator - Revoking previously assigned partitions [] for group testgroup
  152. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Heartbeat thread for group testgroup started
  153. 2017-11-03 19:44:53 INFO BufferedConsumerClientAdapterImpl - onPartitionRevoked: partitions=[]
  154. 2017-11-03 19:44:53 INFO AbstractCoordinator - (Re-)joining group testgroup
  155. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=testgroup, sessionTimeout=10000, rebalanceTimeout=300000, memberId=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@1758ba40)) to coordinator localhost:9092 (id: 2147483647 rack: null)
  156. 2017-11-03 19:44:53 DEBUG Metrics - Added sensor with name node-2147483647.bytes-sent
  157. 2017-11-03 19:44:53 DEBUG Metrics - Added sensor with name node-2147483647.bytes-received
  158. 2017-11-03 19:44:53 DEBUG Metrics - Added sensor with name node-2147483647.latency
  159. 2017-11-03 19:44:53 DEBUG Selector - Created socket with SO_RCVBUF = 342972, SO_SNDBUF = 146988, SO_TIMEOUT = 0 to node 2147483647
  160. 2017-11-03 19:44:53 DEBUG NetworkClient - Completed connection to node 2147483647. Fetching API versions.
  161. 2017-11-03 19:44:53 DEBUG NetworkClient - Initiating API versions fetch from node 2147483647.
  162. 2017-11-03 19:44:53 DEBUG NetworkClient - Recorded API versions for node 2147483647: (Produce(0): 0 to 3 [usable: 3], Fetch(1): 0 to 5 [usable: 5], Offsets(2): 0 to 2 [usable: 2], Metadata(3): 0 to 4 [usable: 4], LeaderAndIsr(4): 0 [usable: 0], StopReplica(5): 0 [usable: 0], UpdateMetadata(6): 0 to 3 [usable: 3], ControlledShutdown(7): 1 [usable: 1], OffsetCommit(8): 0 to 3 [usable: 3], OffsetFetch(9): 0 to 3 [usable: 3], FindCoordinator(10): 0 to 1 [usable: 1], JoinGroup(11): 0 to 2 [usable: 2], Heartbeat(12): 0 to 1 [usable: 1], LeaveGroup(13): 0 to 1 [usable: 1], SyncGroup(14): 0 to 1 [usable: 1], DescribeGroups(15): 0 to 1 [usable: 1], ListGroups(16): 0 to 1 [usable: 1], SaslHandshake(17): 0 [usable: 0], ApiVersions(18): 0 to 1 [usable: 1], CreateTopics(19): 0 to 2 [usable: 2], DeleteTopics(20): 0 to 1 [usable: 1], DeleteRecords(21): 0 [usable: 0], InitProducerId(22): 0 [usable: 0], OffsetForLeaderEpoch(23): 0 [usable: 0], AddPartitionsToTxn(24): 0 [usable: 0], AddOffsetsToTxn(25): 0 [usable: 0], EndTxn(26): 0 [usable: 0], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 [usable: 0], DescribeAcls(29): 0 [usable: 0], CreateAcls(30): 0 [usable: 0], DeleteAcls(31): 0 [usable: 0], DescribeConfigs(32): 0 [usable: 0], AlterConfigs(33): 0 [usable: 0])
  163. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Received successful JoinGroup response for group testgroup: org.apache.kafka.common.requests.JoinGroupResponse@4f3d403e
  164. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Performing assignment for group testgroup using strategy range with subscriptions {consumer-1-15174527-6683-40fc-9205-9f75da4554fa=Subscription(topics=[test])}
  165. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Finished assignment for group testgroup: {consumer-1-15174527-6683-40fc-9205-9f75da4554fa=Assignment(partitions=[test-0, test-1, test-2])}
  166. 2017-11-03 19:44:53 DEBUG AbstractCoordinator - Sending leader SyncGroup for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=testgroup, generationId=1, memberId=consumer-1-15174527-6683-40fc-9205-9f75da4554fa, groupAssignment=consumer-1-15174527-6683-40fc-9205-9f75da4554fa)
  167. 2017-11-03 19:44:53 INFO AbstractCoordinator - Successfully joined group testgroup with generation 1
  168. 2017-11-03 19:44:53 INFO ConsumerCoordinator - Setting newly assigned partitions [test-0, test-1, test-2] for group testgroup
  169. 2017-11-03 19:44:53 INFO BufferedConsumerClientAdapterImpl - onPartitionsAssigned: partitions=[test-0, test-1, test-2]
  170. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Group testgroup fetching committed offsets for partitions: [test-0, test-1, test-2]
  171. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Group testgroup has no committed offset for partition test-0
  172. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Group testgroup has no committed offset for partition test-1
  173. 2017-11-03 19:44:53 DEBUG ConsumerCoordinator - Group testgroup has no committed offset for partition test-2
  174. 2017-11-03 19:44:53 DEBUG Fetcher - Handling ListOffsetResponse response for test-0. Fetched offset 0, timestamp -1
  175. 2017-11-03 19:44:53 DEBUG Fetcher - Handling ListOffsetResponse response for test-1. Fetched offset 0, timestamp -1
  176. 2017-11-03 19:44:53 DEBUG Fetcher - Handling ListOffsetResponse response for test-2. Fetched offset 0, timestamp -1
  177. 2017-11-03 19:44:53 DEBUG Fetcher - Resetting offset for partition test-0 to offset 0.
  178. 2017-11-03 19:44:53 DEBUG Fetcher - Resetting offset for partition test-1 to offset 0.
  179. 2017-11-03 19:44:53 DEBUG Fetcher - Resetting offset for partition test-2 to offset 0.
  180. 2017-11-03 19:44:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 0 to node localhost:9092 (id: 0 rack: null)
  181. 2017-11-03 19:44:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 0 to node localhost:9092 (id: 0 rack: null)
  182. 2017-11-03 19:44:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  183. 2017-11-03 19:44:53 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-0, test-2, test-1] to broker localhost:9092 (id: 0 rack: null)
  184. 2017-11-03 19:44:53 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  185. 2017-11-03 19:44:53 INFO BufferedConsumerClientAdapterImpl - commitOffsets: partitionsToOffsets={}
  186. 2017-11-03 19:44:53 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=3163)
  187. 2017-11-03 19:44:53 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=7421)
  188. 2017-11-03 19:44:53 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  189. 2017-11-03 19:44:56 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  190. 2017-11-03 19:44:56 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  191. 2017-11-03 19:44:58 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  192. 2017-11-03 19:44:58 DEBUG Metrics - Added sensor with name test-0.records-lag
  193. 2017-11-03 19:44:58 DEBUG Metrics - Added sensor with name test-2.records-lag
  194. 2017-11-03 19:44:58 DEBUG Metrics - Added sensor with name topic.test.bytes-fetched
  195. 2017-11-03 19:44:58 DEBUG Metrics - Added sensor with name topic.test.records-fetched
  196. 2017-11-03 19:44:58 DEBUG Metrics - Added sensor with name test-1.records-lag
  197. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  198. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  199. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  200. 2017-11-03 19:44:58 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  201. 2017-11-03 19:44:58 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=10, or 10
  202. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-0, threadId=test-dlgtr-0, partition=0, offset=0, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  203. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-5, threadId=test-dlgtr-5, partition=2, offset=2, sleepMillis=0, key=0, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  204. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-4, threadId=test-dlgtr-4, partition=2, offset=0, sleepMillis=0, key=0, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  205. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-2, threadId=test-dlgtr-2, partition=0, offset=2, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  206. 2017-11-03 19:44:58 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  207. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-1, threadId=test-dlgtr-1, partition=2, offset=1, sleepMillis=0, key=0, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  208. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-3, threadId=test-dlgtr-3, partition=0, offset=1, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  209. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-4, threadId=test-dlgtr-4, partition=2, offset=6, sleepMillis=0, key=3, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  210. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-6, threadId=test-dlgtr-6, partition=2, offset=5, sleepMillis=0, key=2, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  211. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-5, threadId=test-dlgtr-5, partition=2, offset=4, sleepMillis=0, key=2, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  212. 2017-11-03 19:44:58 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-0, threadId=test-dlgtr-0, partition=2, offset=3, sleepMillis=0, key=2, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  213. 2017-11-03 19:44:58 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  214. 2017-11-03 19:44:58 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  215. 2017-11-03 19:44:58 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  216. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  217. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  218. 2017-11-03 19:44:58 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  219. 2017-11-03 19:44:58 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  220. 2017-11-03 19:44:58 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  221. 2017-11-03 19:44:58 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  222. 2017-11-03 19:44:59 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  223. 2017-11-03 19:44:59 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  224. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  225. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  226. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  227. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  228. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  229. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  230. 2017-11-03 19:44:59 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  231. 2017-11-03 19:44:59 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  232. 2017-11-03 19:44:59 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  233. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  234. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  235. 2017-11-03 19:44:59 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  236. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  237. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  238. 2017-11-03 19:44:59 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  239. 2017-11-03 19:44:59 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  240. 2017-11-03 19:44:59 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  241. 2017-11-03 19:44:59 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  242. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  243. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  244. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  245. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  246. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  247. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  248. 2017-11-03 19:45:00 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  249. 2017-11-03 19:45:00 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  250. 2017-11-03 19:45:00 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  251. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  252. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  253. 2017-11-03 19:45:00 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  254. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  255. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  256. 2017-11-03 19:45:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  257. 2017-11-03 19:45:00 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  258. 2017-11-03 19:45:00 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  259. 2017-11-03 19:45:00 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  260. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  261. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  262. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  263. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  264. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  265. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  266. 2017-11-03 19:45:01 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  267. 2017-11-03 19:45:01 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  268. 2017-11-03 19:45:01 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  269. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  270. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  271. 2017-11-03 19:45:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  272. 2017-11-03 19:45:01 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  273. 2017-11-03 19:45:01 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  274. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  275. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  276. 2017-11-03 19:45:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  277. 2017-11-03 19:45:01 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  278. 2017-11-03 19:45:02 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  279. 2017-11-03 19:45:02 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  280. 2017-11-03 19:45:02 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  281. 2017-11-03 19:45:02 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  282. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  283. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  284. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  285. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  286. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  287. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  288. 2017-11-03 19:45:02 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  289. 2017-11-03 19:45:02 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  290. 2017-11-03 19:45:02 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  291. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  292. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  293. 2017-11-03 19:45:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  294. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  295. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  296. 2017-11-03 19:45:02 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  297. 2017-11-03 19:45:02 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  298. 2017-11-03 19:45:03 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  299. 2017-11-03 19:45:03 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  300. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  301. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  302. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  303. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  304. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  305. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  306. 2017-11-03 19:45:03 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  307. 2017-11-03 19:45:03 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  308. 2017-11-03 19:45:03 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  309. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  310. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  311. 2017-11-03 19:45:03 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  312. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  313. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  314. 2017-11-03 19:45:03 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  315. 2017-11-03 19:45:03 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  316. 2017-11-03 19:45:04 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  317. 2017-11-03 19:45:04 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  318. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  319. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  320. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  321. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  322. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  323. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  324. 2017-11-03 19:45:04 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  325. 2017-11-03 19:45:04 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  326. 2017-11-03 19:45:04 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  327. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  328. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  329. 2017-11-03 19:45:04 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  330. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  331. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  332. 2017-11-03 19:45:04 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  333. 2017-11-03 19:45:04 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  334. 2017-11-03 19:45:05 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  335. 2017-11-03 19:45:05 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  336. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  337. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  338. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  339. 2017-11-03 19:45:05 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  340. 2017-11-03 19:45:05 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  341. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  342. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  343. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  344. 2017-11-03 19:45:05 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  345. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  346. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  347. 2017-11-03 19:45:05 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  348. 2017-11-03 19:45:05 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  349. 2017-11-03 19:45:05 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  350. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  351. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  352. 2017-11-03 19:45:05 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  353. 2017-11-03 19:45:05 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  354. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  355. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  356. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  357. 2017-11-03 19:45:06 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  358. 2017-11-03 19:45:06 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  359. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  360. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  361. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  362. 2017-11-03 19:45:06 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  363. 2017-11-03 19:45:06 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  364. 2017-11-03 19:45:06 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  365. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  366. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  367. 2017-11-03 19:45:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  368. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  369. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  370. 2017-11-03 19:45:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  371. 2017-11-03 19:45:06 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  372. 2017-11-03 19:45:06 INFO DriverStatsPrinter - Total Duration (nanos)=6,250,863,000.00, Processed Messages Throughput (records/sec)=1.67, Processed Messages Throughput (bytes/s)=1,708.33, Processed Messages=10, Processed Message Avg. Time (nanos)=834,700.00, Processed Messages Cumulative Time (nanos)=8,347,000.00
  373. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  374. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  375. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  376. 2017-11-03 19:45:07 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  377. 2017-11-03 19:45:07 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  378. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  379. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  380. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  381. 2017-11-03 19:45:07 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  382. 2017-11-03 19:45:07 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  383. 2017-11-03 19:45:07 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  384. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  385. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  386. 2017-11-03 19:45:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  387. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  388. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  389. 2017-11-03 19:45:07 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  390. 2017-11-03 19:45:07 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  391. 2017-11-03 19:45:08 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  392. 2017-11-03 19:45:08 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  393. 2017-11-03 19:45:08 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  394. 2017-11-03 19:45:08 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  395. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  396. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  397. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  398. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  399. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  400. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  401. 2017-11-03 19:45:08 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  402. 2017-11-03 19:45:08 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  403. 2017-11-03 19:45:08 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  404. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  405. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  406. 2017-11-03 19:45:08 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  407. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  408. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  409. 2017-11-03 19:45:08 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  410. 2017-11-03 19:45:08 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  411. 2017-11-03 19:45:09 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  412. 2017-11-03 19:45:09 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  413. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  414. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  415. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  416. 2017-11-03 19:45:09 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  417. 2017-11-03 19:45:09 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  418. 2017-11-03 19:45:09 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  419. 2017-11-03 19:45:09 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  420. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  421. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  422. 2017-11-03 19:45:09 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  423. 2017-11-03 19:45:09 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  424. 2017-11-03 19:45:11 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  425. 2017-11-03 19:45:11 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  426. 2017-11-03 19:45:14 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  427. 2017-11-03 19:45:14 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  428. 2017-11-03 19:45:14 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  429. 2017-11-03 19:45:14 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  430. 2017-11-03 19:45:14 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  431. 2017-11-03 19:45:14 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  432. 2017-11-03 19:45:14 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  433. 2017-11-03 19:45:15 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  434. 2017-11-03 19:45:15 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  435. 2017-11-03 19:45:15 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  436. 2017-11-03 19:45:15 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  437. 2017-11-03 19:45:17 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  438. 2017-11-03 19:45:17 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  439. 2017-11-03 19:45:20 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  440. 2017-11-03 19:45:20 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  441. 2017-11-03 19:45:20 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  442. 2017-11-03 19:45:20 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  443. 2017-11-03 19:45:20 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  444. 2017-11-03 19:45:20 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  445. 2017-11-03 19:45:20 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  446. 2017-11-03 19:45:20 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  447. 2017-11-03 19:45:20 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  448. 2017-11-03 19:45:20 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  449. 2017-11-03 19:45:20 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  450. 2017-11-03 19:45:21 INFO DriverStatsPrinter - Total Duration (nanos)=6,250,863,000.00, Processed Messages Throughput (records/sec)=1.67, Processed Messages Throughput (bytes/s)=1,708.33, Processed Messages=10, Processed Message Avg. Time (nanos)=834,700.00, Processed Messages Cumulative Time (nanos)=8,347,000.00
  451. 2017-11-03 19:45:23 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  452. 2017-11-03 19:45:23 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  453. 2017-11-03 19:45:25 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  454. 2017-11-03 19:45:25 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  455. 2017-11-03 19:45:25 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  456. 2017-11-03 19:45:25 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  457. 2017-11-03 19:45:25 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  458. 2017-11-03 19:45:26 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  459. 2017-11-03 19:45:26 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  460. 2017-11-03 19:45:26 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  461. 2017-11-03 19:45:26 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  462. 2017-11-03 19:45:26 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  463. 2017-11-03 19:45:26 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  464. 2017-11-03 19:45:29 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  465. 2017-11-03 19:45:29 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  466. 2017-11-03 19:45:31 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  467. 2017-11-03 19:45:31 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  468. 2017-11-03 19:45:31 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  469. 2017-11-03 19:45:31 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  470. 2017-11-03 19:45:31 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  471. 2017-11-03 19:45:31 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  472. 2017-11-03 19:45:31 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  473. 2017-11-03 19:45:31 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  474. 2017-11-03 19:45:31 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  475. 2017-11-03 19:45:32 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  476. 2017-11-03 19:45:32 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  477. 2017-11-03 19:45:35 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  478. 2017-11-03 19:45:35 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  479. 2017-11-03 19:45:36 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  480. 2017-11-03 19:45:36 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  481. 2017-11-03 19:45:36 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  482. 2017-11-03 19:45:36 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  483. 2017-11-03 19:45:36 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  484. 2017-11-03 19:45:36 INFO DriverStatsPrinter - Total Duration (nanos)=6,250,863,000.00, Processed Messages Throughput (records/sec)=1.67, Processed Messages Throughput (bytes/s)=1,708.33, Processed Messages=10, Processed Message Avg. Time (nanos)=834,700.00, Processed Messages Cumulative Time (nanos)=8,347,000.00
  485. 2017-11-03 19:45:37 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  486. 2017-11-03 19:45:37 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  487. 2017-11-03 19:45:37 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  488. 2017-11-03 19:45:37 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  489. 2017-11-03 19:45:38 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  490. 2017-11-03 19:45:38 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  491. 2017-11-03 19:45:41 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  492. 2017-11-03 19:45:41 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  493. 2017-11-03 19:45:42 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  494. 2017-11-03 19:45:42 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  495. 2017-11-03 19:45:42 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  496. 2017-11-03 19:45:42 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  497. 2017-11-03 19:45:42 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  498. 2017-11-03 19:45:42 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  499. 2017-11-03 19:45:42 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  500. 2017-11-03 19:45:42 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  501. 2017-11-03 19:45:42 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  502. 2017-11-03 19:45:44 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  503. 2017-11-03 19:45:44 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  504. 2017-11-03 19:45:47 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  505. 2017-11-03 19:45:47 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  506. 2017-11-03 19:45:47 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  507. 2017-11-03 19:45:47 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  508. 2017-11-03 19:45:47 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-2 at offset 7 to node localhost:9092 (id: 0 rack: null)
  509. 2017-11-03 19:45:47 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0, test-2] to broker localhost:9092 (id: 0 rack: null)
  510. 2017-11-03 19:45:47 DEBUG AbstractCoordinator - Attempt to heartbeat failed for group testgroup since it is rebalancing.
  511. 2017-11-03 19:45:47 INFO ConsumerCoordinator - Revoking previously assigned partitions [test-0, test-1, test-2] for group testgroup
  512. 2017-11-03 19:45:47 INFO BufferedConsumerClientAdapterImpl - onPartitionRevoked: partitions=[test-0, test-1, test-2]
  513. 2017-11-03 19:45:47 INFO AbstractCoordinator - (Re-)joining group testgroup
  514. 2017-11-03 19:45:47 DEBUG AbstractCoordinator - Sending JoinGroup ((type: JoinGroupRequest, groupId=testgroup, sessionTimeout=10000, rebalanceTimeout=300000, memberId=consumer-1-15174527-6683-40fc-9205-9f75da4554fa, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@6c616fde)) to coordinator localhost:9092 (id: 2147483647 rack: null)
  515. 2017-11-03 19:45:47 DEBUG AbstractCoordinator - Received successful JoinGroup response for group testgroup: org.apache.kafka.common.requests.JoinGroupResponse@70f78f68
  516. 2017-11-03 19:45:47 DEBUG ConsumerCoordinator - Performing assignment for group testgroup using strategy range with subscriptions {consumer-1-900b1610-7e93-4f12-82e5-c33183c2871a=Subscription(topics=[test]), consumer-1-15174527-6683-40fc-9205-9f75da4554fa=Subscription(topics=[test])}
  517. 2017-11-03 19:45:47 DEBUG ConsumerCoordinator - Finished assignment for group testgroup: {consumer-1-900b1610-7e93-4f12-82e5-c33183c2871a=Assignment(partitions=[test-2]), consumer-1-15174527-6683-40fc-9205-9f75da4554fa=Assignment(partitions=[test-0, test-1])}
  518. 2017-11-03 19:45:47 DEBUG AbstractCoordinator - Sending leader SyncGroup for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=testgroup, generationId=2, memberId=consumer-1-15174527-6683-40fc-9205-9f75da4554fa, groupAssignment=consumer-1-900b1610-7e93-4f12-82e5-c33183c2871a,consumer-1-15174527-6683-40fc-9205-9f75da4554fa)
  519. 2017-11-03 19:45:47 INFO AbstractCoordinator - Successfully joined group testgroup with generation 2
  520. 2017-11-03 19:45:47 DEBUG Metrics - Removed sensor with name test-2.records-lag
  521. 2017-11-03 19:45:47 INFO ConsumerCoordinator - Setting newly assigned partitions [test-0, test-1] for group testgroup
  522. 2017-11-03 19:45:47 INFO BufferedConsumerClientAdapterImpl - onPartitionsAssigned: partitions=[test-0, test-1]
  523. 2017-11-03 19:45:47 DEBUG ConsumerCoordinator - Group testgroup fetching committed offsets for partitions: [test-0, test-1]
  524. 2017-11-03 19:45:47 DEBUG ConsumerCoordinator - Group testgroup has no committed offset for partition test-0
  525. 2017-11-03 19:45:47 DEBUG ConsumerCoordinator - Group testgroup has no committed offset for partition test-1
  526. 2017-11-03 19:45:48 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  527. 2017-11-03 19:45:48 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  528. 2017-11-03 19:45:48 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 7 for partition test-2 returned fetch data (error=NONE, highWaterMark=7, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  529. 2017-11-03 19:45:48 DEBUG Fetcher - Handling ListOffsetResponse response for test-0. Fetched offset 0, timestamp -1
  530. 2017-11-03 19:45:48 DEBUG Fetcher - Handling ListOffsetResponse response for test-1. Fetched offset 0, timestamp -1
  531. 2017-11-03 19:45:48 DEBUG Fetcher - Resetting offset for partition test-0 to offset 0.
  532. 2017-11-03 19:45:48 DEBUG Fetcher - Resetting offset for partition test-1 to offset 0.
  533. 2017-11-03 19:45:48 DEBUG Fetcher - Discarding stale fetch response for partition test-0 since its offset 3 does not match the expected offset 0
  534. 2017-11-03 19:45:48 DEBUG Fetcher - Ignoring fetched records for partition test-2 since it is no longer fetchable
  535. 2017-11-03 19:45:48 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  536. 2017-11-03 19:45:48 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 0 to node localhost:9092 (id: 0 rack: null)
  537. 2017-11-03 19:45:48 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  538. 2017-11-03 19:45:48 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  539. 2017-11-03 19:45:48 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  540. 2017-11-03 19:45:48 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=3163)
  541. 2017-11-03 19:45:50 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  542. 2017-11-03 19:45:50 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  543. 2017-11-03 19:45:51 INFO DriverStatsPrinter - Total Duration (nanos)=6,250,863,000.00, Processed Messages Throughput (records/sec)=1.67, Processed Messages Throughput (bytes/s)=1,708.33, Processed Messages=10, Processed Message Avg. Time (nanos)=834,700.00, Processed Messages Cumulative Time (nanos)=8,347,000.00
  544. 2017-11-03 19:45:53 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  545. 2017-11-03 19:45:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  546. 2017-11-03 19:45:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  547. 2017-11-03 19:45:53 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  548. 2017-11-03 19:45:53 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=3, or 3
  549. 2017-11-03 19:45:53 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  550. 2017-11-03 19:45:53 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-2, threadId=test-dlgtr-2, partition=0, offset=0, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  551. 2017-11-03 19:45:53 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-5, threadId=test-dlgtr-5, partition=0, offset=2, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  552. 2017-11-03 19:45:53 INFO KafkaConsumerDriverRecordProcessor - ProcessorId=processor-0, threadId=test-dlgtr-0, partition=0, offset=1, sleepMillis=0, key=1, value=VCMOZTHRMMHMLXGYXPSCIKFBNJJYBHDOZAMUVPZLXORCWNCRWYGPWGBANLYBBLTIIWKTQXNLYXBFTUBALULDTYPEKCOQTJXMJYYPXFNYZMUZLAEZLYTNIAHRYVDTUQNSIPQTBBFISUURBIIZYVVIHEVDPYBDXWQESONRHVWVZUBUGQQHIIKDHNWAFNFVWCBQLMCPEMOTMJAWMMPOBPSYFECPHTOCANEGPGBPPMXNZZYAVMAAWLPZSJSOUNMJZDRRZLFNSXGZMVVNKYCGTOHAFNJLKNBYMUEXPUHNQNGNAASERIORFEAALCCBCWMPWVYASDFFRYREBRAFYOKVLDOVTVSOSZCBUUBHHFSXOEZAUJXODDFRZBMUOKIQBBLVNDDKSNYRTEKEJENAZTBUNDSHDCZXPNGARSCKFUXRFURABBHEAOGRLNPRVIQSTUQNIXATOLPXNMNWCTOTWTXSNKUHPHWABKLWBWFBLGWLSGSMARGMMFWPRHRFTSPRTEVYMOUMSISIESICRGELBYGDXQPOCHIRFEZKFHFCPKARNLGFYELNOFKQLSZJIRVWPUYMVNYQMRZWOXTGKQTZIUWYFWBPGYWQZMQJEYABJWDKUKKDLLSDOIIHGXPIOWSFZWKUPWVZJXKXZYKAHUVETXMLJQGXJXQYZEZXDGNTVTIYBHYZJQNNKCTVMOHDBPCYXBLPHMOIFLPAPLWQQXISSEWEYSSIQHYJTAUBLAMLOGXWIRFWIYTCHBNQOGJVVBLVZHDLBUDIIHPDTHZNIRDUKPOTUZZZEZDWXUJOWOQDHAAFINYOPQCMPRPHDCPWFFLYIOAZPENEOGGEWIWRDVWTTSFWNWRBRRPMAJCANZIUNCPJTRASVOKYIYXHANKRNUNPMQOEJHJWBLCHEUHUJOBCDWJTOMHEBKWDKGFKZYVJCGQHTENEKBBZAWLYNJCJGJOKHJOZFWPLMQCAZZPZKCCLLNYWFKRPWXKUNMDXUDPXVIUCVPZKAQNSVPDHEXNGEWKNSXWGNUAA
  553. 2017-11-03 19:45:53 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  554. 2017-11-03 19:45:53 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  555. 2017-11-03 19:45:53 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  556. 2017-11-03 19:45:53 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  557. 2017-11-03 19:45:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  558. 2017-11-03 19:45:53 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  559. 2017-11-03 19:45:53 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  560. 2017-11-03 19:45:53 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  561. 2017-11-03 19:45:53 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  562. 2017-11-03 19:45:54 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  563. 2017-11-03 19:45:54 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  564. 2017-11-03 19:45:54 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  565. 2017-11-03 19:45:54 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  566. 2017-11-03 19:45:54 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  567. 2017-11-03 19:45:54 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  568. 2017-11-03 19:45:54 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  569. 2017-11-03 19:45:54 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  570. 2017-11-03 19:45:54 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  571. 2017-11-03 19:45:54 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  572. 2017-11-03 19:45:54 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  573. 2017-11-03 19:45:54 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  574. 2017-11-03 19:45:54 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  575. 2017-11-03 19:45:54 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  576. 2017-11-03 19:45:55 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  577. 2017-11-03 19:45:55 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  578. 2017-11-03 19:45:55 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  579. 2017-11-03 19:45:55 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  580. 2017-11-03 19:45:55 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  581. 2017-11-03 19:45:55 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  582. 2017-11-03 19:45:55 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  583. 2017-11-03 19:45:55 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  584. 2017-11-03 19:45:55 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  585. 2017-11-03 19:45:55 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  586. 2017-11-03 19:45:56 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  587. 2017-11-03 19:45:57 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  588. 2017-11-03 19:45:59 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  589. 2017-11-03 19:46:00 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  590. 2017-11-03 19:46:00 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  591. 2017-11-03 19:46:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  592. 2017-11-03 19:46:00 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  593. 2017-11-03 19:46:00 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  594. 2017-11-03 19:46:01 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  595. 2017-11-03 19:46:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  596. 2017-11-03 19:46:01 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  597. 2017-11-03 19:46:02 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  598. 2017-11-03 19:46:03 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  599. 2017-11-03 19:46:05 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  600. 2017-11-03 19:46:06 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  601. 2017-11-03 19:46:06 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  602. 2017-11-03 19:46:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  603. 2017-11-03 19:46:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  604. 2017-11-03 19:46:06 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  605. 2017-11-03 19:46:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  606. 2017-11-03 19:46:06 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  607. 2017-11-03 19:46:06 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  608. 2017-11-03 19:46:06 INFO DriverStatsPrinter - Total Duration (nanos)=61,395,345,000.00, Processed Messages Throughput (records/sec)=.21, Processed Messages Throughput (bytes/s)=218.44, Processed Messages=13, Processed Message Avg. Time (nanos)=680,461.54, Processed Messages Cumulative Time (nanos)=8,846,000.00
  609. 2017-11-03 19:46:09 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  610. 2017-11-03 19:46:09 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  611. 2017-11-03 19:46:11 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  612. 2017-11-03 19:46:11 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  613. 2017-11-03 19:46:11 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  614. 2017-11-03 19:46:11 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  615. 2017-11-03 19:46:12 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  616. 2017-11-03 19:46:12 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  617. 2017-11-03 19:46:12 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  618. 2017-11-03 19:46:12 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  619. 2017-11-03 19:46:12 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  620. 2017-11-03 19:46:15 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  621. 2017-11-03 19:46:15 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  622. 2017-11-03 19:46:17 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  623. 2017-11-03 19:46:17 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  624. 2017-11-03 19:46:17 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  625. 2017-11-03 19:46:17 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  626. 2017-11-03 19:46:17 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  627. 2017-11-03 19:46:17 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  628. 2017-11-03 19:46:17 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  629. 2017-11-03 19:46:18 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  630. 2017-11-03 19:46:18 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  631. 2017-11-03 19:46:21 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  632. 2017-11-03 19:46:21 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  633. 2017-11-03 19:46:21 INFO DriverStatsPrinter - Total Duration (nanos)=61,395,345,000.00, Processed Messages Throughput (records/sec)=.21, Processed Messages Throughput (bytes/s)=218.44, Processed Messages=13, Processed Message Avg. Time (nanos)=680,461.54, Processed Messages Cumulative Time (nanos)=8,846,000.00
  634. 2017-11-03 19:46:22 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  635. 2017-11-03 19:46:22 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  636. 2017-11-03 19:46:22 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  637. 2017-11-03 19:46:22 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  638. 2017-11-03 19:46:23 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  639. 2017-11-03 19:46:23 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  640. 2017-11-03 19:46:23 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  641. 2017-11-03 19:46:24 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  642. 2017-11-03 19:46:24 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  643. 2017-11-03 19:46:27 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  644. 2017-11-03 19:46:27 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  645. 2017-11-03 19:46:28 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  646. 2017-11-03 19:46:28 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  647. 2017-11-03 19:46:28 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  648. 2017-11-03 19:46:28 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  649. 2017-11-03 19:46:28 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  650. 2017-11-03 19:46:28 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  651. 2017-11-03 19:46:28 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  652. 2017-11-03 19:46:30 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  653. 2017-11-03 19:46:30 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  654. 2017-11-03 19:46:33 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  655. 2017-11-03 19:46:33 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  656. 2017-11-03 19:46:33 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  657. 2017-11-03 19:46:33 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  658. 2017-11-03 19:46:33 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  659. 2017-11-03 19:46:33 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  660. 2017-11-03 19:46:34 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  661. 2017-11-03 19:46:34 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  662. 2017-11-03 19:46:34 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  663. 2017-11-03 19:46:36 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  664. 2017-11-03 19:46:36 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  665. 2017-11-03 19:46:36 INFO DriverStatsPrinter - Total Duration (nanos)=61,395,345,000.00, Processed Messages Throughput (records/sec)=.21, Processed Messages Throughput (bytes/s)=218.44, Processed Messages=13, Processed Message Avg. Time (nanos)=680,461.54, Processed Messages Cumulative Time (nanos)=8,846,000.00
  666. 2017-11-03 19:46:39 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  667. 2017-11-03 19:46:39 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  668. 2017-11-03 19:46:39 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  669. 2017-11-03 19:46:39 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  670. 2017-11-03 19:46:39 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  671. 2017-11-03 19:46:39 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  672. 2017-11-03 19:46:39 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  673. 2017-11-03 19:46:39 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  674. 2017-11-03 19:46:39 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  675. 2017-11-03 19:46:42 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  676. 2017-11-03 19:46:42 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  677. 2017-11-03 19:46:44 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  678. 2017-11-03 19:46:44 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  679. 2017-11-03 19:46:44 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  680. 2017-11-03 19:46:44 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  681. 2017-11-03 19:46:45 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  682. 2017-11-03 19:46:45 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  683. 2017-11-03 19:46:45 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  684. 2017-11-03 19:46:45 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  685. 2017-11-03 19:46:45 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  686. 2017-11-03 19:46:48 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  687. 2017-11-03 19:46:48 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  688. 2017-11-03 19:46:50 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  689. 2017-11-03 19:46:50 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  690. 2017-11-03 19:46:50 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  691. 2017-11-03 19:46:50 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  692. 2017-11-03 19:46:50 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  693. 2017-11-03 19:46:50 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  694. 2017-11-03 19:46:50 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  695. 2017-11-03 19:46:51 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  696. 2017-11-03 19:46:51 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  697. 2017-11-03 19:46:51 INFO DriverStatsPrinter - Total Duration (nanos)=61,395,345,000.00, Processed Messages Throughput (records/sec)=.21, Processed Messages Throughput (bytes/s)=218.44, Processed Messages=13, Processed Message Avg. Time (nanos)=680,461.54, Processed Messages Cumulative Time (nanos)=8,846,000.00
  698. 2017-11-03 19:46:54 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  699. 2017-11-03 19:46:54 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  700. 2017-11-03 19:46:55 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  701. 2017-11-03 19:46:55 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  702. 2017-11-03 19:46:55 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  703. 2017-11-03 19:46:55 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  704. 2017-11-03 19:46:56 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  705. 2017-11-03 19:46:56 INFO BufferedConsumerClientAdapterImpl - commitOffsets: partitionsToOffsets={0=3, 2=7}
  706. 2017-11-03 19:46:56 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  707. 2017-11-03 19:46:56 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  708. 2017-11-03 19:46:56 DEBUG ConsumerCoordinator - Group testgroup committed offset 3 for partition test-0
  709. 2017-11-03 19:46:56 DEBUG ConsumerCoordinator - Group testgroup committed offset 7 for partition test-2
  710. 2017-11-03 19:46:57 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  711. 2017-11-03 19:46:57 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  712. 2017-11-03 19:47:00 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  713. 2017-11-03 19:47:00 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  714. 2017-11-03 19:47:01 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  715. 2017-11-03 19:47:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  716. 2017-11-03 19:47:01 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  717. 2017-11-03 19:47:01 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  718. 2017-11-03 19:47:01 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  719. 2017-11-03 19:47:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  720. 2017-11-03 19:47:02 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  721. 2017-11-03 19:47:03 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  722. 2017-11-03 19:47:03 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  723. 2017-11-03 19:47:06 DEBUG AbstractCoordinator - Sending Heartbeat request for group testgroup to coordinator localhost:9092 (id: 2147483647 rack: null)
  724. 2017-11-03 19:47:06 DEBUG AbstractCoordinator - Received successful Heartbeat response for group testgroup
  725. 2017-11-03 19:47:06 INFO DriverStatsPrinter - Total Duration (nanos)=61,395,345,000.00, Processed Messages Throughput (records/sec)=.21, Processed Messages Throughput (bytes/s)=218.44, Processed Messages=13, Processed Message Avg. Time (nanos)=680,461.54, Processed Messages Cumulative Time (nanos)=8,846,000.00
  726. 2017-11-03 19:47:06 INFO BufferedConsumerClientAdapterImpl - prefetchRecords: calling consumer.poll().
  727. 2017-11-03 19:47:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-1 at offset 0 to node localhost:9092 (id: 0 rack: null)
  728. 2017-11-03 19:47:06 DEBUG Fetcher - Added READ_UNCOMMITTED fetch request for partition test-0 at offset 3 to node localhost:9092 (id: 0 rack: null)
  729. 2017-11-03 19:47:06 DEBUG Fetcher - Sending READ_UNCOMMITTED fetch for partitions [test-1, test-0] to broker localhost:9092 (id: 0 rack: null)
  730. 2017-11-03 19:47:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 0 for partition test-1 returned fetch data (error=NONE, highWaterMark=0, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  731. 2017-11-03 19:47:07 DEBUG Fetcher - Fetch READ_UNCOMMITTED at offset 3 for partition test-0 returned fetch data (error=NONE, highWaterMark=3, lastStableOffset = -1, logStartOffset = 0, abortedTransactions = null, recordsSizeInBytes=0)
  732. 2017-11-03 19:47:07 TRACE BufferedConsumerClientAdapterImpl - Received consumer records from Kafka. record count=0
  733.  
  734. Process finished with exit code 130
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!