o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Preparing to read 0 bytes of data for partition project.events.output-0 with offset 331
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Updating high watermark for partition project.events.output-0 to 331
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Returning fetched records at offset 331 for assigned partition project.events.output-0 and update position to 331
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Skipping fetch for partition project.events.output-1 because there is an in-flight request to broker5:9092 (id: 12 rack: null)
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Added READ_UNCOMMITTED fetch request for partition project.events.output-2 at offset 328 to node broker6:9092 (id: 13 rack: null)
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Added READ_UNCOMMITTED fetch request for partition project.events.output-0 at offset 331 to node broker4:9092 (id: 11 rack: null)
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Sending READ_UNCOMMITTED fetch for partitions [project.events.output-2] to broker broker6:9092 (id: 13 rack: null)
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Sending READ_UNCOMMITTED fetch for partitions [project.events.output-0] to broker broker4:9092 (id: 11 rack: null)
org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,topics=[{topic=project.events.output,partitions=[{partition=2,fetch_offset=328,log_start_offset=-1,max_bytes=1048576}]}]} with correlation id 2014 to node 13
org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Sending FETCH {replica_id=-1,max_wait_time=500,min_bytes=1,max_bytes=52428800,isolation_level=0,topics=[{topic=project.events.output,partitions=[{partition=0,fetch_offset=331,log_start_offset=-1,max_bytes=1048576}]}]} with correlation id 2015 to node 11
org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6] Completed receive from node 12 for FETCH with correlation id 2013, received {throttle_time_ms=0,responses=[{topic=project.events.output,partition_responses=[{partition_header={partition=1,error_code=0,high_watermark=331,last_stable_offset=-1,log_start_offset=66,aborted_transactions=null},record_set=[]}]}]}
o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-2, groupId=[service.groupid].output-6]