Apr26 17:16:05.726|INFO|ConsumerConfig values: 
	metric.reporters = []
	metadata.max.age.ms = 300000
	value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	group.id = delayed-task-bug-consumer-group
	partition.assignment.strategy = [org.apache.kafka.clients.consumer.RangeAssignor]
	reconnect.backoff.ms = 50
	sasl.kerberos.ticket.renew.window.factor = 0.8
	max.partition.fetch.bytes = 64
	bootstrap.servers = [localhost:9092]
	retry.backoff.ms = 100
	sasl.kerberos.kinit.cmd = /usr/bin/kinit
	sasl.kerberos.service.name = null
	sasl.kerberos.ticket.renew.jitter = 0.05
	ssl.keystore.type = JKS
	ssl.trustmanager.algorithm = PKIX
	enable.auto.commit = true
	ssl.key.password = null
	fetch.max.wait.ms = 500
	sasl.kerberos.min.time.before.relogin = 60000
	connections.max.idle.ms = 540000
	ssl.truststore.password = null
	session.timeout.ms = 6000
	metrics.num.samples = 2
	client.id = 
	ssl.endpoint.identification.algorithm = null
	key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer
	ssl.protocol = TLS
	check.crcs = true
	request.timeout.ms = 40000
	ssl.provider = null
	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
	ssl.keystore.location = null
	heartbeat.interval.ms = 1000
	auto.commit.interval.ms = 5000
	receive.buffer.bytes = 32768
	ssl.cipher.suites = null
	ssl.truststore.type = JKS
	security.protocol = PLAINTEXT
	ssl.truststore.location = null
	ssl.keystore.password = null
	ssl.keymanager.algorithm = SunX509
	metrics.sample.window.ms = 30000
	fetch.min.bytes = 1
	send.buffer.bytes = 131072
	auto.offset.reset = latest

Apr26 17:16:05.727|DEBUG|Starting the Kafka consumer
Apr26 17:16:05.737|DEBUG|Updated cluster metadata version 1 to Cluster(nodes = [Node(-1, localhost, 9092)], partitions = [])
Apr26 17:16:05.750|DEBUG|Added sensor with name connections-closed:client-id-consumer-1
Apr26 17:16:05.822|DEBUG|Added sensor with name connections-created:client-id-consumer-1
Apr26 17:16:05.822|DEBUG|Added sensor with name bytes-sent-received:client-id-consumer-1
Apr26 17:16:05.823|DEBUG|Added sensor with name bytes-sent:client-id-consumer-1
Apr26 17:16:05.824|DEBUG|Added sensor with name bytes-received:client-id-consumer-1
Apr26 17:16:05.824|DEBUG|Added sensor with name select-time:client-id-consumer-1
Apr26 17:16:05.825|DEBUG|Added sensor with name io-time:client-id-consumer-1
Apr26 17:16:05.846|DEBUG|Added sensor with name heartbeat-latency
Apr26 17:16:05.847|DEBUG|Added sensor with name join-latency
Apr26 17:16:05.847|DEBUG|Added sensor with name sync-latency
Apr26 17:16:05.849|DEBUG|Added sensor with name commit-latency
Apr26 17:16:05.856|DEBUG|Added sensor with name bytes-fetched
Apr26 17:16:05.857|DEBUG|Added sensor with name records-fetched
Apr26 17:16:05.857|DEBUG|Added sensor with name fetch-latency
Apr26 17:16:05.858|DEBUG|Added sensor with name records-lag
Apr26 17:16:05.858|DEBUG|Added sensor with name fetch-throttle-time
Apr26 17:16:05.862|INFO|Kafka version : 0.9.0.1
Apr26 17:16:05.862|INFO|Kafka commitId : 23c69d62a0cabf06
Apr26 17:16:05.864|DEBUG|Kafka consumer created
Apr26 17:16:05.865|DEBUG|Subscribed to topic(s): delayed-task-bug-repro4
Apr26 17:16:05.865|DEBUG|Issuing group metadata request to broker -1
Apr26 17:16:05.878|DEBUG|Initiating connection to node -1 at localhost:9092.
Apr26 17:16:05.939|DEBUG|Added sensor with name node--1.bytes-sent
Apr26 17:16:05.939|DEBUG|Added sensor with name node--1.bytes-received
Apr26 17:16:05.940|DEBUG|Added sensor with name node--1.latency
Apr26 17:16:05.941|DEBUG|Completed connection to node -1
Apr26 17:16:05.980|DEBUG|Sending metadata request ClientRequest(expectResponse=true, callback=null, request=RequestSend(header={api_key=3,api_version=0,correlation_id=1,client_id=consumer-1}, body={topics=[delayed-task-bug-repro4]}), isInitiatedByNetworkClient, createdTimeMs=1461705365978, sendTimeMs=0) to node -1
Apr26 17:16:05.995|DEBUG|Updated cluster metadata version 2 to Cluster(nodes = [Node(1, roblaptop, 9093), Node(0, roblaptop, 9092)], partitions = [Partition(topic = delayed-task-bug-repro4, partition = 9, leader = 1, replicas = [1,], isr = [1,], Partition(topic = delayed-task-bug-repro4, partition = 8, leader = 0, replicas = [0,], isr = [0,], Partition(topic = delayed-task-bug-repro4, partition = 7, leader = 1, replicas = [1,], isr = [1,], Partition(topic = delayed-task-bug-repro4, partition = 6, leader = 0, replicas = [0,], isr = [0,], Partition(topic = delayed-task-bug-repro4, partition = 5, leader = 1, replicas = [1,], isr = [1,], Partition(topic = delayed-task-bug-repro4, partition = 4, leader = 0, replicas = [0,], isr = [0,], Partition(topic = delayed-task-bug-repro4, partition = 3, leader = 1, replicas = [1,], isr = [1,], Partition(topic = delayed-task-bug-repro4, partition = 2, leader = 0, replicas = [0,], isr = [0,], Partition(topic = delayed-task-bug-repro4, partition = 1, leader = 1, replicas = [1,], isr = [1,], Partition(topic = delayed-task-bug-repro4, partition = 0, leader = 0, replicas = [0,], isr = [0,]])
Apr26 17:16:05.999|DEBUG|Issuing group metadata request to broker 1
Apr26 17:16:05.999|DEBUG|Initiating connection to node 1 at roblaptop:9093.
Apr26 17:16:05.999|DEBUG|Added sensor with name node-1.bytes-sent
Apr26 17:16:06.001|DEBUG|Added sensor with name node-1.bytes-received
Apr26 17:16:06.002|DEBUG|Added sensor with name node-1.latency
Apr26 17:16:06.003|DEBUG|Completed connection to node 1
Apr26 17:16:06.030|DEBUG|Group metadata response ClientResponse(receivedTimeMs=1461705366030, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2c039ac6, request=RequestSend(header={api_key=10,api_version=0,correlation_id=2,client_id=consumer-1}, body={group_id=delayed-task-bug-consumer-group}), createdTimeMs=1461705365999, sendTimeMs=1461705366003), responseBody={error_code=0,coordinator={node_id=0,host=roblaptop,port=9092}})
Apr26 17:16:06.031|DEBUG|Initiating connection to node 2147483647 at roblaptop:9092.
Apr26 17:16:06.033|DEBUG|Revoking previously assigned partitions []
Apr26 17:16:06.033|DEBUG|(Re-)joining group delayed-task-bug-consumer-group
Apr26 17:16:06.037|DEBUG|Issuing request (JOIN_GROUP: {group_id=delayed-task-bug-consumer-group,session_timeout=6000,member_id=,protocol_type=consumer,group_protocols=[{protocol_name=range,protocol_metadata=java.nio.HeapByteBuffer[pos=0 lim=35 cap=35]}]}) to coordinator 2147483647
Apr26 17:16:06.038|DEBUG|Added sensor with name node-2147483647.bytes-sent
Apr26 17:16:06.038|DEBUG|Added sensor with name node-2147483647.bytes-received
Apr26 17:16:06.039|DEBUG|Added sensor with name node-2147483647.latency
Apr26 17:16:06.039|DEBUG|Completed connection to node 2147483647
Apr26 17:16:06.047|DEBUG|Joined group: {error_code=0,generation_id=1,group_protocol=range,leader_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,member_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,members=[{member_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,member_metadata=java.nio.HeapByteBuffer[pos=0 lim=35 cap=35]}]}
Apr26 17:16:06.048|DEBUG|Performing range assignment for subscriptions {consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4=org.apache.kafka.clients.consumer.internals.PartitionAssignor$Subscription@e874448}
Apr26 17:16:06.049|DEBUG|Finished assignment: {consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4=org.apache.kafka.clients.consumer.internals.PartitionAssignor$Assignment@7113b13f}
Apr26 17:16:06.050|DEBUG|Issuing leader SyncGroup (SYNC_GROUP: {group_id=delayed-task-bug-consumer-group,generation_id=1,member_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,group_assignment=[{member_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=79 cap=79]}]}) to coordinator 2147483647
Apr26 17:16:06.057|DEBUG|Received successful sync group response for group delayed-task-bug-consumer-group: {error_code=0,member_assignment=java.nio.HeapByteBuffer[pos=0 lim=79 cap=79]}
Apr26 17:16:06.058|DEBUG|Setting newly assigned partitions [delayed-task-bug-repro4-9, delayed-task-bug-repro4-8, delayed-task-bug-repro4-7, delayed-task-bug-repro4-6, delayed-task-bug-repro4-5, delayed-task-bug-repro4-4, delayed-task-bug-repro4-3, delayed-task-bug-repro4-2, delayed-task-bug-repro4-1, delayed-task-bug-repro4-0]
Apr26 17:16:06.059|INFO|Partitions assigned
Apr26 17:16:06.059|DEBUG|Fetching committed offsets for partitions: [delayed-task-bug-repro4-9, delayed-task-bug-repro4-8, delayed-task-bug-repro4-7, delayed-task-bug-repro4-6, delayed-task-bug-repro4-5, delayed-task-bug-repro4-4, delayed-task-bug-repro4-3, delayed-task-bug-repro4-2, delayed-task-bug-repro4-1, delayed-task-bug-repro4-0]
Apr26 17:16:06.065|DEBUG|No committed offset for partition delayed-task-bug-repro4-9
Apr26 17:16:06.066|DEBUG|No committed offset for partition delayed-task-bug-repro4-8
Apr26 17:16:06.066|DEBUG|No committed offset for partition delayed-task-bug-repro4-7
Apr26 17:16:06.066|DEBUG|No committed offset for partition delayed-task-bug-repro4-6
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-5
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-4
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-3
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-2
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-1
Apr26 17:16:06.067|DEBUG|No committed offset for partition delayed-task-bug-repro4-0
Apr26 17:16:06.067|DEBUG|Resetting offset for partition delayed-task-bug-repro4-9 to latest offset.
Apr26 17:16:06.081|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-9
Apr26 17:16:06.082|DEBUG|Resetting offset for partition delayed-task-bug-repro4-8 to latest offset.
Apr26 17:16:06.082|DEBUG|Initiating connection to node 0 at roblaptop:9092.
Apr26 17:16:06.082|DEBUG|Added sensor with name node-0.bytes-sent
Apr26 17:16:06.083|DEBUG|Added sensor with name node-0.bytes-received
Apr26 17:16:06.083|DEBUG|Added sensor with name node-0.latency
Apr26 17:16:06.084|DEBUG|Completed connection to node 0
Apr26 17:16:06.087|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-8
Apr26 17:16:06.087|DEBUG|Resetting offset for partition delayed-task-bug-repro4-7 to latest offset.
Apr26 17:16:06.091|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-7
Apr26 17:16:06.091|DEBUG|Resetting offset for partition delayed-task-bug-repro4-6 to latest offset.
Apr26 17:16:06.094|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-6
Apr26 17:16:06.094|DEBUG|Resetting offset for partition delayed-task-bug-repro4-5 to latest offset.
Apr26 17:16:06.097|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-5
Apr26 17:16:06.097|DEBUG|Resetting offset for partition delayed-task-bug-repro4-4 to latest offset.
Apr26 17:16:06.099|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-4
Apr26 17:16:06.099|DEBUG|Resetting offset for partition delayed-task-bug-repro4-3 to latest offset.
Apr26 17:16:06.102|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-3
Apr26 17:16:06.102|DEBUG|Resetting offset for partition delayed-task-bug-repro4-2 to latest offset.
Apr26 17:16:06.104|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-2
Apr26 17:16:06.104|DEBUG|Resetting offset for partition delayed-task-bug-repro4-1 to latest offset.
Apr26 17:16:06.106|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-1
Apr26 17:16:06.107|DEBUG|Resetting offset for partition delayed-task-bug-repro4-0 to latest offset.
Apr26 17:16:06.109|DEBUG|Fetched offset 10 for partition delayed-task-bug-repro4-0
Apr26 17:16:06.109|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 10
Apr26 17:16:06.109|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 10
Apr26 17:16:06.110|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 10
Apr26 17:16:06.515|INFO|No more records - starting over
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-9
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-8
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-7
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-6
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-5
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-4
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-3
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-2
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-1
Apr26 17:16:06.516|DEBUG|Seeking to beginning of partition delayed-task-bug-repro4-0
Apr26 17:16:06.516|DEBUG|Resetting offset for partition delayed-task-bug-repro4-9 to earliest offset.
Apr26 17:16:06.621|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-8 since it is no longer fetchable
Apr26 17:16:06.621|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-6 since it is no longer fetchable
Apr26 17:16:06.621|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-4 since it is no longer fetchable
Apr26 17:16:06.621|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-2 since it is no longer fetchable
Apr26 17:16:06.627|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-0 since it is no longer fetchable
Apr26 17:16:06.631|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-9 since it is no longer fetchable
Apr26 17:16:06.631|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-7 since it is no longer fetchable
Apr26 17:16:06.631|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-5 since it is no longer fetchable
Apr26 17:16:06.632|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-3 since it is no longer fetchable
Apr26 17:16:06.632|DEBUG|Ignoring fetched records for partition delayed-task-bug-repro4-1 since it is no longer fetchable
Apr26 17:16:06.636|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-9
Apr26 17:16:06.636|DEBUG|Resetting offset for partition delayed-task-bug-repro4-8 to earliest offset.
Apr26 17:16:06.639|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-8
Apr26 17:16:06.639|DEBUG|Resetting offset for partition delayed-task-bug-repro4-7 to earliest offset.
Apr26 17:16:06.641|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-7
Apr26 17:16:06.642|DEBUG|Resetting offset for partition delayed-task-bug-repro4-6 to earliest offset.
Apr26 17:16:06.644|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-6
Apr26 17:16:06.645|DEBUG|Resetting offset for partition delayed-task-bug-repro4-5 to earliest offset.
Apr26 17:16:06.646|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-5
Apr26 17:16:06.646|DEBUG|Resetting offset for partition delayed-task-bug-repro4-4 to earliest offset.
Apr26 17:16:06.647|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-4
Apr26 17:16:06.647|DEBUG|Resetting offset for partition delayed-task-bug-repro4-3 to earliest offset.
Apr26 17:16:06.650|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-3
Apr26 17:16:06.650|DEBUG|Resetting offset for partition delayed-task-bug-repro4-2 to earliest offset.
Apr26 17:16:06.654|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-2
Apr26 17:16:06.654|DEBUG|Resetting offset for partition delayed-task-bug-repro4-1 to earliest offset.
Apr26 17:16:06.656|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-1
Apr26 17:16:06.656|DEBUG|Resetting offset for partition delayed-task-bug-repro4-0 to earliest offset.
Apr26 17:16:06.657|DEBUG|Fetched offset 0 for partition delayed-task-bug-repro4-0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 0
Apr26 17:16:06.657|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 0
Apr26 17:16:06.658|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 0
Apr26 17:16:06.658|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 0
Apr26 17:16:06.658|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 0
Apr26 17:16:06.673|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 0 to buffered record list
Apr26 17:16:06.673|DEBUG|Added sensor with name topic.delayed-task-bug-repro4.bytes-fetched
Apr26 17:16:06.673|DEBUG|Added sensor with name topic.delayed-task-bug-repro4.records-fetched
Apr26 17:16:06.674|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 0 to buffered record list
Apr26 17:16:06.674|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 0 to buffered record list
Apr26 17:16:06.674|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 0 to buffered record list
Apr26 17:16:06.674|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 0 to buffered record list
Apr26 17:16:06.674|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-8 and update position to 1
Apr26 17:16:06.674|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-6 and update position to 1
Apr26 17:16:06.675|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-4 and update position to 1
Apr26 17:16:06.675|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-2 and update position to 1
Apr26 17:16:06.675|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-0 and update position to 1
Apr26 17:16:06.675|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 1
Apr26 17:16:06.675|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 1
Apr26 17:16:06.675|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 1
Apr26 17:16:06.675|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 1
Apr26 17:16:06.675|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 1
Apr26 17:16:06.676|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 0 to buffered record list
Apr26 17:16:06.676|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 0 to buffered record list
Apr26 17:16:06.677|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 0 to buffered record list
Apr26 17:16:06.677|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 0 to buffered record list
Apr26 17:16:06.677|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 0 to buffered record list
Apr26 17:16:06.677|INFO|Simulating message processing...
Apr26 17:16:08.179|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-9 and update position to 1
Apr26 17:16:08.179|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-7 and update position to 1
Apr26 17:16:08.179|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-5 and update position to 1
Apr26 17:16:08.179|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-3 and update position to 1
Apr26 17:16:08.179|TRACE|Returning fetched records at offset 0 for assigned partition delayed-task-bug-repro4-1 and update position to 1
Apr26 17:16:08.179|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 1
Apr26 17:16:08.179|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 1
Apr26 17:16:08.179|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 1
Apr26 17:16:08.179|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 1
Apr26 17:16:08.179|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 1
Apr26 17:16:08.180|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 1 to buffered record list
Apr26 17:16:08.181|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 1 to buffered record list
Apr26 17:16:08.181|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 1 to buffered record list
Apr26 17:16:08.181|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 1 to buffered record list
Apr26 17:16:08.181|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 1 to buffered record list
Apr26 17:16:08.181|INFO|Simulating message processing...
Apr26 17:16:09.681|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-8 and update position to 2
Apr26 17:16:09.682|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-6 and update position to 2
Apr26 17:16:09.682|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-4 and update position to 2
Apr26 17:16:09.683|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-2 and update position to 2
Apr26 17:16:09.683|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-0 and update position to 2
Apr26 17:16:09.684|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 2
Apr26 17:16:09.684|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 2
Apr26 17:16:09.684|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 2
Apr26 17:16:09.685|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 2
Apr26 17:16:09.685|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 2
Apr26 17:16:09.688|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 1 to buffered record list
Apr26 17:16:09.689|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 1 to buffered record list
Apr26 17:16:09.690|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 1 to buffered record list
Apr26 17:16:09.690|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 1 to buffered record list
Apr26 17:16:09.691|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 1 to buffered record list
Apr26 17:16:09.692|INFO|Simulating message processing...
Apr26 17:16:11.192|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-9 and update position to 2
Apr26 17:16:11.193|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-7 and update position to 2
Apr26 17:16:11.193|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-5 and update position to 2
Apr26 17:16:11.193|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-3 and update position to 2
Apr26 17:16:11.193|TRACE|Returning fetched records at offset 1 for assigned partition delayed-task-bug-repro4-1 and update position to 2
Apr26 17:16:11.193|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 2
Apr26 17:16:11.193|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 2
Apr26 17:16:11.193|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 2
Apr26 17:16:11.193|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 2
Apr26 17:16:11.194|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 2
Apr26 17:16:11.195|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 2 to buffered record list
Apr26 17:16:11.195|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 2 to buffered record list
Apr26 17:16:11.195|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 2 to buffered record list
Apr26 17:16:11.195|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 2 to buffered record list
Apr26 17:16:11.196|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 2 to buffered record list
Apr26 17:16:11.196|INFO|Simulating message processing...
Apr26 17:16:12.696|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-8 and update position to 3
Apr26 17:16:12.696|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-6 and update position to 3
Apr26 17:16:12.697|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-4 and update position to 3
Apr26 17:16:12.697|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-2 and update position to 3
Apr26 17:16:12.697|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-0 and update position to 3
Apr26 17:16:12.697|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 3
Apr26 17:16:12.697|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 3
Apr26 17:16:12.697|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 3
Apr26 17:16:12.698|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 3
Apr26 17:16:12.698|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 3
Apr26 17:16:12.699|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 2 to buffered record list
Apr26 17:16:12.699|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 2 to buffered record list
Apr26 17:16:12.700|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 2 to buffered record list
Apr26 17:16:12.700|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 2 to buffered record list
Apr26 17:16:12.700|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 2 to buffered record list
Apr26 17:16:12.700|INFO|Simulating message processing...
Apr26 17:16:14.200|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-9 and update position to 3
Apr26 17:16:14.201|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-7 and update position to 3
Apr26 17:16:14.201|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-5 and update position to 3
Apr26 17:16:14.201|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-3 and update position to 3
Apr26 17:16:14.201|TRACE|Returning fetched records at offset 2 for assigned partition delayed-task-bug-repro4-1 and update position to 3
Apr26 17:16:14.201|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 3
Apr26 17:16:14.201|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 3
Apr26 17:16:14.201|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 3
Apr26 17:16:14.202|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 3
Apr26 17:16:14.202|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 3
Apr26 17:16:14.202|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 3 to buffered record list
Apr26 17:16:14.203|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 3 to buffered record list
Apr26 17:16:14.203|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 3 to buffered record list
Apr26 17:16:14.203|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 3 to buffered record list
Apr26 17:16:14.203|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 3 to buffered record list
Apr26 17:16:14.203|INFO|Simulating message processing...
Apr26 17:16:15.703|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-8 and update position to 4
Apr26 17:16:15.704|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-6 and update position to 4
Apr26 17:16:15.704|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-4 and update position to 4
Apr26 17:16:15.704|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-2 and update position to 4
Apr26 17:16:15.704|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-0 and update position to 4
Apr26 17:16:15.704|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 4
Apr26 17:16:15.704|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 4
Apr26 17:16:15.704|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 4
Apr26 17:16:15.704|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 4
Apr26 17:16:15.704|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 4
Apr26 17:16:15.705|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 3 to buffered record list
Apr26 17:16:15.705|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 3 to buffered record list
Apr26 17:16:15.706|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 3 to buffered record list
Apr26 17:16:15.706|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 3 to buffered record list
Apr26 17:16:15.706|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 3 to buffered record list
Apr26 17:16:15.706|INFO|Simulating message processing...
Apr26 17:16:17.206|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-9 and update position to 4
Apr26 17:16:17.207|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-7 and update position to 4
Apr26 17:16:17.207|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-5 and update position to 4
Apr26 17:16:17.207|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-3 and update position to 4
Apr26 17:16:17.207|TRACE|Returning fetched records at offset 3 for assigned partition delayed-task-bug-repro4-1 and update position to 4
Apr26 17:16:17.207|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 4
Apr26 17:16:17.207|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 4
Apr26 17:16:17.207|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 4
Apr26 17:16:17.207|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 4
Apr26 17:16:17.207|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 4
Apr26 17:16:17.208|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 4 to buffered record list
Apr26 17:16:17.208|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 4 to buffered record list
Apr26 17:16:17.209|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 4 to buffered record list
Apr26 17:16:17.209|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 4 to buffered record list
Apr26 17:16:17.209|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 4 to buffered record list
Apr26 17:16:17.209|INFO|Simulating message processing...
Apr26 17:16:18.709|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-8 and update position to 5
Apr26 17:16:18.710|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-6 and update position to 5
Apr26 17:16:18.710|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-4 and update position to 5
Apr26 17:16:18.710|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-2 and update position to 5
Apr26 17:16:18.710|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-0 and update position to 5
Apr26 17:16:18.710|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 5
Apr26 17:16:18.710|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 5
Apr26 17:16:18.710|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 5
Apr26 17:16:18.710|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 5
Apr26 17:16:18.711|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 5
Apr26 17:16:18.711|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 4 to buffered record list
Apr26 17:16:18.711|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 4 to buffered record list
Apr26 17:16:18.712|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 4 to buffered record list
Apr26 17:16:18.712|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 4 to buffered record list
Apr26 17:16:18.712|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 4 to buffered record list
Apr26 17:16:18.712|INFO|Simulating message processing...
Apr26 17:16:20.212|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-9 and update position to 5
Apr26 17:16:20.212|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-7 and update position to 5
Apr26 17:16:20.213|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-5 and update position to 5
Apr26 17:16:20.213|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-3 and update position to 5
Apr26 17:16:20.213|TRACE|Returning fetched records at offset 4 for assigned partition delayed-task-bug-repro4-1 and update position to 5
Apr26 17:16:20.213|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 5
Apr26 17:16:20.213|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 5
Apr26 17:16:20.213|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 5
Apr26 17:16:20.213|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 5
Apr26 17:16:20.213|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 5
Apr26 17:16:20.214|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 5 to buffered record list
Apr26 17:16:20.214|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 5 to buffered record list
Apr26 17:16:20.214|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 5 to buffered record list
Apr26 17:16:20.214|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 5 to buffered record list
Apr26 17:16:20.214|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 5 to buffered record list
Apr26 17:16:20.214|INFO|Simulating message processing...
Apr26 17:16:21.714|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-8 and update position to 6
Apr26 17:16:21.715|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-6 and update position to 6
Apr26 17:16:21.715|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-4 and update position to 6
Apr26 17:16:21.715|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-2 and update position to 6
Apr26 17:16:21.715|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-0 and update position to 6
Apr26 17:16:21.715|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 6
Apr26 17:16:21.715|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 6
Apr26 17:16:21.715|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 6
Apr26 17:16:21.715|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 6
Apr26 17:16:21.715|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 6
Apr26 17:16:21.716|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 5 to buffered record list
Apr26 17:16:21.716|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 5 to buffered record list
Apr26 17:16:21.716|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 5 to buffered record list
Apr26 17:16:21.717|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 5 to buffered record list
Apr26 17:16:21.717|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 5 to buffered record list
Apr26 17:16:21.717|INFO|Simulating message processing...
Apr26 17:16:23.217|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-9 and update position to 6
Apr26 17:16:23.217|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-7 and update position to 6
Apr26 17:16:23.217|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-5 and update position to 6
Apr26 17:16:23.218|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-3 and update position to 6
Apr26 17:16:23.218|TRACE|Returning fetched records at offset 5 for assigned partition delayed-task-bug-repro4-1 and update position to 6
Apr26 17:16:23.218|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 6
Apr26 17:16:23.218|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 6
Apr26 17:16:23.218|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 6
Apr26 17:16:23.218|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 6
Apr26 17:16:23.218|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 6
Apr26 17:16:23.219|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 6 to buffered record list
Apr26 17:16:23.219|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 6 to buffered record list
Apr26 17:16:23.220|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 6 to buffered record list
Apr26 17:16:23.220|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 6 to buffered record list
Apr26 17:16:23.220|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 6 to buffered record list
Apr26 17:16:23.221|INFO|Simulating message processing...
Apr26 17:16:24.721|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-8 and update position to 7
Apr26 17:16:24.721|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-6 and update position to 7
Apr26 17:16:24.721|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-4 and update position to 7
Apr26 17:16:24.721|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-2 and update position to 7
Apr26 17:16:24.721|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-0 and update position to 7
Apr26 17:16:24.722|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 7
Apr26 17:16:24.722|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 7
Apr26 17:16:24.722|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 7
Apr26 17:16:24.722|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 7
Apr26 17:16:24.722|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 7
Apr26 17:16:24.722|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 6 to buffered record list
Apr26 17:16:24.723|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 6 to buffered record list
Apr26 17:16:24.723|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 6 to buffered record list
Apr26 17:16:24.723|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 6 to buffered record list
Apr26 17:16:24.723|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 6 to buffered record list
Apr26 17:16:24.723|INFO|Simulating message processing...
Apr26 17:16:26.223|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-9 and update position to 7
Apr26 17:16:26.223|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-7 and update position to 7
Apr26 17:16:26.224|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-5 and update position to 7
Apr26 17:16:26.224|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-3 and update position to 7
Apr26 17:16:26.224|TRACE|Returning fetched records at offset 6 for assigned partition delayed-task-bug-repro4-1 and update position to 7
Apr26 17:16:26.224|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 7
Apr26 17:16:26.224|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 7
Apr26 17:16:26.224|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 7
Apr26 17:16:26.224|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 7
Apr26 17:16:26.224|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 7
Apr26 17:16:26.225|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 7 to buffered record list
Apr26 17:16:26.225|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 7 to buffered record list
Apr26 17:16:26.225|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 7 to buffered record list
Apr26 17:16:26.225|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 7 to buffered record list
Apr26 17:16:26.225|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 7 to buffered record list
Apr26 17:16:26.225|INFO|Simulating message processing...
Apr26 17:16:27.725|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-8 and update position to 8
Apr26 17:16:27.726|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-6 and update position to 8
Apr26 17:16:27.726|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-4 and update position to 8
Apr26 17:16:27.726|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-2 and update position to 8
Apr26 17:16:27.726|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-0 and update position to 8
Apr26 17:16:27.726|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 8
Apr26 17:16:27.726|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 8
Apr26 17:16:27.726|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 8
Apr26 17:16:27.726|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 8
Apr26 17:16:27.726|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 8
Apr26 17:16:27.727|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 7 to buffered record list
Apr26 17:16:27.727|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 7 to buffered record list
Apr26 17:16:27.727|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 7 to buffered record list
Apr26 17:16:27.727|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 7 to buffered record list
Apr26 17:16:27.727|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 7 to buffered record list
Apr26 17:16:27.727|INFO|Simulating message processing...
Apr26 17:16:29.228|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-9 and update position to 8
Apr26 17:16:29.228|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-7 and update position to 8
Apr26 17:16:29.228|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-5 and update position to 8
Apr26 17:16:29.228|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-3 and update position to 8
Apr26 17:16:29.228|TRACE|Returning fetched records at offset 7 for assigned partition delayed-task-bug-repro4-1 and update position to 8
Apr26 17:16:29.228|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 8
Apr26 17:16:29.228|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 8
Apr26 17:16:29.228|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 8
Apr26 17:16:29.228|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 8
Apr26 17:16:29.228|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 8
Apr26 17:16:29.229|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 8 to buffered record list
Apr26 17:16:29.229|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 8 to buffered record list
Apr26 17:16:29.229|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 8 to buffered record list
Apr26 17:16:29.229|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 8 to buffered record list
Apr26 17:16:29.229|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 8 to buffered record list
Apr26 17:16:29.230|INFO|Simulating message processing...
Apr26 17:16:30.730|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-8 and update position to 9
Apr26 17:16:30.730|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-6 and update position to 9
Apr26 17:16:30.730|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-4 and update position to 9
Apr26 17:16:30.730|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-2 and update position to 9
Apr26 17:16:30.731|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-0 and update position to 9
Apr26 17:16:30.731|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 9
Apr26 17:16:30.731|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 9
Apr26 17:16:30.731|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 9
Apr26 17:16:30.731|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 9
Apr26 17:16:30.731|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 9
Apr26 17:16:30.732|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 8 to buffered record list
Apr26 17:16:30.732|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 8 to buffered record list
Apr26 17:16:30.732|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 8 to buffered record list
Apr26 17:16:30.732|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 8 to buffered record list
Apr26 17:16:30.732|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 8 to buffered record list
Apr26 17:16:30.732|INFO|Simulating message processing...
Apr26 17:16:32.233|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-9 and update position to 9
Apr26 17:16:32.233|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-7 and update position to 9
Apr26 17:16:32.233|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-5 and update position to 9
Apr26 17:16:32.233|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-3 and update position to 9
Apr26 17:16:32.233|TRACE|Returning fetched records at offset 8 for assigned partition delayed-task-bug-repro4-1 and update position to 9
Apr26 17:16:32.233|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 9
Apr26 17:16:32.233|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 9
Apr26 17:16:32.233|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 9
Apr26 17:16:32.233|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 9
Apr26 17:16:32.233|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 9
Apr26 17:16:32.234|TRACE|Adding fetched record for partition delayed-task-bug-repro4-8 with offset 9 to buffered record list
Apr26 17:16:32.234|TRACE|Adding fetched record for partition delayed-task-bug-repro4-6 with offset 9 to buffered record list
Apr26 17:16:32.234|TRACE|Adding fetched record for partition delayed-task-bug-repro4-4 with offset 9 to buffered record list
Apr26 17:16:32.234|TRACE|Adding fetched record for partition delayed-task-bug-repro4-2 with offset 9 to buffered record list
Apr26 17:16:32.234|TRACE|Adding fetched record for partition delayed-task-bug-repro4-0 with offset 9 to buffered record list
Apr26 17:16:32.234|INFO|Simulating message processing...
Apr26 17:16:33.735|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-8 and update position to 10
Apr26 17:16:33.735|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-6 and update position to 10
Apr26 17:16:33.735|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-4 and update position to 10
Apr26 17:16:33.735|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-2 and update position to 10
Apr26 17:16:33.735|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-0 and update position to 10
Apr26 17:16:33.735|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 10
Apr26 17:16:33.735|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 10
Apr26 17:16:33.735|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 10
Apr26 17:16:33.735|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 10
Apr26 17:16:33.735|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 10
Apr26 17:16:33.736|TRACE|Adding fetched record for partition delayed-task-bug-repro4-9 with offset 9 to buffered record list
Apr26 17:16:33.736|TRACE|Adding fetched record for partition delayed-task-bug-repro4-7 with offset 9 to buffered record list
Apr26 17:16:33.736|TRACE|Adding fetched record for partition delayed-task-bug-repro4-5 with offset 9 to buffered record list
Apr26 17:16:33.736|TRACE|Adding fetched record for partition delayed-task-bug-repro4-3 with offset 9 to buffered record list
Apr26 17:16:33.736|TRACE|Adding fetched record for partition delayed-task-bug-repro4-1 with offset 9 to buffered record list
Apr26 17:16:33.736|INFO|Simulating message processing...
Apr26 17:16:35.236|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-9 and update position to 10
Apr26 17:16:35.237|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-7 and update position to 10
Apr26 17:16:35.237|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-5 and update position to 10
Apr26 17:16:35.237|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-3 and update position to 10
Apr26 17:16:35.237|TRACE|Returning fetched records at offset 9 for assigned partition delayed-task-bug-repro4-1 and update position to 10
Apr26 17:16:35.237|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 10
Apr26 17:16:35.237|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 10
Apr26 17:16:35.237|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 10
Apr26 17:16:35.237|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 10
Apr26 17:16:35.237|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 10
Apr26 17:16:35.238|INFO|Simulating message processing...
Apr26 17:16:36.738|TRACE|Added fetch request for partition delayed-task-bug-repro4-8 at offset 10
Apr26 17:16:36.738|TRACE|Added fetch request for partition delayed-task-bug-repro4-6 at offset 10
Apr26 17:16:36.738|TRACE|Added fetch request for partition delayed-task-bug-repro4-4 at offset 10
Apr26 17:16:36.738|TRACE|Added fetch request for partition delayed-task-bug-repro4-2 at offset 10
Apr26 17:16:36.738|TRACE|Added fetch request for partition delayed-task-bug-repro4-0 at offset 10
Apr26 17:16:36.739|INFO|Marking the coordinator 2147483647 dead.
Apr26 17:16:36.739|DEBUG|Cannot auto-commit offsets now since the coordinator is unknown, will retry after backoff
Apr26 17:16:36.740|DEBUG|Issuing group metadata request to broker 1
Apr26 17:16:36.743|DEBUG|Group metadata response ClientResponse(receivedTimeMs=1461705396743, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@2a70a3d8, request=RequestSend(header={api_key=10,api_version=0,correlation_id=51,client_id=consumer-1}, body={group_id=delayed-task-bug-consumer-group}), createdTimeMs=1461705396740, sendTimeMs=1461705396740), responseBody={error_code=0,coordinator={node_id=0,host=roblaptop,port=9092}})
Apr26 17:16:36.743|TRACE|Added fetch request for partition delayed-task-bug-repro4-9 at offset 10
Apr26 17:16:36.743|TRACE|Added fetch request for partition delayed-task-bug-repro4-7 at offset 10
Apr26 17:16:36.743|TRACE|Added fetch request for partition delayed-task-bug-repro4-5 at offset 10
Apr26 17:16:36.743|TRACE|Added fetch request for partition delayed-task-bug-repro4-3 at offset 10
Apr26 17:16:36.743|TRACE|Added fetch request for partition delayed-task-bug-repro4-1 at offset 10
Apr26 17:16:36.841|TRACE|Sending offset-commit request with {delayed-task-bug-repro4-9=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-8=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-7=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-6=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-5=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-4=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-3=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-2=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-1=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-0=OffsetAndMetadata{offset=10, metadata=''}} to Node(2147483647, roblaptop, 9092)
Apr26 17:16:36.846|ERROR|Error ILLEGAL_GENERATION occurred while committing offsets for group delayed-task-bug-consumer-group
Apr26 17:16:36.846|WARN|Auto offset commit failed: Commit cannot be completed due to group rebalance
Apr26 17:16:36.846|TRACE|Sending offset-commit request with {delayed-task-bug-repro4-9=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-8=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-7=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-6=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-5=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-4=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-3=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-2=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-1=OffsetAndMetadata{offset=10, metadata=''}, delayed-task-bug-repro4-0=OffsetAndMetadata{offset=10, metadata=''}} to Node(2147483647, roblaptop, 9092)
Apr26 17:16:36.847|ERROR|Error ILLEGAL_GENERATION occurred while committing offsets for group delayed-task-bug-consumer-group
Apr26 17:16:36.847|WARN|Auto offset commit failed: 
Apr26 17:16:36.847|DEBUG|Revoking previously assigned partitions [delayed-task-bug-repro4-9, delayed-task-bug-repro4-8, delayed-task-bug-repro4-7, delayed-task-bug-repro4-6, delayed-task-bug-repro4-5, delayed-task-bug-repro4-4, delayed-task-bug-repro4-3, delayed-task-bug-repro4-2, delayed-task-bug-repro4-1, delayed-task-bug-repro4-0]
Apr26 17:16:36.847|WARN|Partitions revoked
Apr26 17:16:36.847|ERROR|Consumer group rebalanced
Apr26 17:16:36.848|DEBUG|(Re-)joining group delayed-task-bug-consumer-group
Apr26 17:16:36.848|DEBUG|Issuing request (JOIN_GROUP: {group_id=delayed-task-bug-consumer-group,session_timeout=6000,member_id=consumer-1-953f42b1-0f34-4ce2-b61d-c7935afaf4a4,protocol_type=consumer,group_protocols=[{protocol_name=range,protocol_metadata=java.nio.HeapByteBuffer[pos=0 lim=35 cap=35]}]}) to coordinator 2147483647
Apr26 17:16:36.853|ERROR|Exception while consuming
org.apache.kafka.common.errors.WakeupException: null
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:324) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:222) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:311) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:890) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]
	at com.inin.DelayedTaskBugConsumer.reproduce(DelayedTaskBugConsumer.java:68) ~[rbu.test-1.0-SNAPSHOT-jar-with-dependencies.jar:na]