2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 1 records
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Creating new transaction with name [null]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state READY to IN_TRANSACTION
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Created Kafka transaction on producer [brave.kafka.clients.TracingProducer@203e561b]
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] l.a.BatchMessagingMessageListenerAdapter : Processing [GenericMessage [payload=[data], headers={kafka_offset=[439], kafka_consumer=brave.kafka.clients.TracingConsumer@695e3928, kafka_timestampType=[CREATE_TIME], kafka_receivedMessageKey=[null], kafka_receivedPartitionId=[0], kafka_receivedTopic=[trans-topic], kafka_receivedTimestamp=[1531397618039], kafka_batchConvertedHeaders=[{X-B3-SpanId=[B@6f6b3cd3, X-B3-ParentSpanId=[B@8e4a5e8, X-B3-Sampled=[B@3a500e23, X-B3-TraceId=[B@680c19fc}]}]]
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Sending offsets to transaction: {trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}}
2018-07-12 15:13:49.189 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Begin adding offsets {trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}} for consumer group mygrp42 to transaction
2018-07-12 15:13:49.190 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Enqueuing transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42)
2018-07-12 15:13:49.190 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.191 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Successfully added partition for consumer group mygrp42 to transaction
2018-07-12 15:13:49.191 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=TxnOffsetCommitRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42, offsets={trans-topic-0=CommittedOffset(offset=440, metadata='')}) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.192 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Successfully added offsets {trans-topic-0=CommittedOffset(offset=440, metadata='')} from consumer group mygrp42 to transaction.
2018-07-12 15:13:49.192 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Initiating transaction commit
2018-07-12 15:13:49.192 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state IN_TRANSACTION to COMMITTING_TRANSACTION
2018-07-12 15:13:49.192 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Enqueuing transactional request (type=EndTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, result=COMMIT)
2018-07-12 15:13:49.192 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=EndTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, result=COMMIT) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.193 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state COMMITTING_TRANSACTION to READY
2018-07-12 15:13:49.193 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:49.692 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.196 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.699 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.699 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.699 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:50.699 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.699 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.700 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:50.700 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.204 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.205 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.707 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.708 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:51.790 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:13:51.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:52.195 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:13:52.196 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:13:52.210 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.210 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.210 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.210 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.211 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.211 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.211 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.712 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.712 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.713 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:52.713 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.713 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.713 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:52.713 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.215 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.215 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.215 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.216 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.216 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.216 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.216 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.720 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.720 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.721 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:53.721 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.721 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.721 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:53.721 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.224 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.729 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:54.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:13:54.794 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:55.200 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:13:55.200 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:13:55.232 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.232 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.232 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.232 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.233 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.233 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.233 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:55.736 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.238 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.238 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.238 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.239 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.239 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.239 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.239 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.742 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.742 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.742 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:56.742 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.743 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.743 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:56.743 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.246 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.247 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.517 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [l-1 housekeeper] com.zaxxer.hikari.pool.HikariPool        : HikariPool-1 - Pool stats (total=10, active=0, idle=10, waiting=0)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.750 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:57.794 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:13:57.796 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:58.203 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:13:58.203 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.254 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.758 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.766 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.767 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:58.767 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.767 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.767 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:58.767 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.270 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.773 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.773 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.774 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:13:59.774 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.774 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.774 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:13:59.774 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.277 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.780 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.780 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.780 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:00.780 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.780 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.781 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.781 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:00.795 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:00.796 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:14:01.205 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:14:01.206 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.283 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.284 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:01.787 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.289 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.289 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.289 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.290 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.290 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.290 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.290 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:02.792 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.294 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.295 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.795 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:03.798 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:14:04.211 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:14:04.214 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:04.303 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.306 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.306 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.306 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.306 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.307 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.307 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:04.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.810 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:04.810 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.312 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.312 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.312 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.312 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.313 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.313 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.313 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.816 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:05.817 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.321 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.795 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:06.807 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:14:06.824 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.824 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.824 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:06.825 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.825 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.825 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:06.825 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.219 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:14:07.219 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.330 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:07.833 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.337 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.840 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.840 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.840 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:08.840 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.840 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.841 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.841 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.343 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.343 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.343 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.344 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-1 at offset 56 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.344 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.344 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-0 at offset 441 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.344 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-1, trans-topic-2, trans-topic-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.797 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:09.798 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Attempt to heartbeat failed since group is rebalancing
2018-07-12 15:14:09.799  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Revoking previously assigned partitions [trans-topic-1, trans-topic-0, trans-topic-2]
2018-07-12 15:14:09.799  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked: [trans-topic-1, trans-topic-0, trans-topic-2]
2018-07-12 15:14:09.799 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:09.799 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Disabling heartbeat thread
2018-07-12 15:14:09.799  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] (Re-)joining group
2018-07-12 15:14:09.799 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending JoinGroup ((type: JoinGroupRequest, groupId=mygrp42, sessionTimeout=15000, rebalanceTimeout=10000, memberId=consumer-1-e924f777-e5eb-43f1-b0b7-35a64f0a9298, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@5e373d8a)) to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:09.801 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful JoinGroup response: org.apache.kafka.common.requests.JoinGroupResponse@73510841
2018-07-12 15:14:09.801 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Performing assignment using strategy range with subscriptions {consumer-1-3dcfe3d4-3c0d-42d6-8079-1f6a63d0e283=Subscription(topics=[trans-topic]), consumer-1-e924f777-e5eb-43f1-b0b7-35a64f0a9298=Subscription(topics=[trans-topic])}
2018-07-12 15:14:09.801 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Finished assignment for group: {consumer-1-3dcfe3d4-3c0d-42d6-8079-1f6a63d0e283=Assignment(partitions=[trans-topic-0, trans-topic-1]), consumer-1-e924f777-e5eb-43f1-b0b7-35a64f0a9298=Assignment(partitions=[trans-topic-2])}
2018-07-12 15:14:09.802 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending leader SyncGroup to coordinator localhost:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=mygrp42, generationId=313, memberId=consumer-1-e924f777-e5eb-43f1-b0b7-35a64f0a9298, groupAssignment=consumer-1-3dcfe3d4-3c0d-42d6-8079-1f6a63d0e283,consumer-1-e924f777-e5eb-43f1-b0b7-35a64f0a9298)
2018-07-12 15:14:09.803  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Successfully joined group with generation 313
2018-07-12 15:14:09.803 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Enabling heartbeat thread
2018-07-12 15:14:09.803 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] org.apache.kafka.common.metrics.Metrics  : Removed sensor with name trans-topic-1.records-lag
2018-07-12 15:14:09.803 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] org.apache.kafka.common.metrics.Metrics  : Removed sensor with name trans-topic-0.records-lag
2018-07-12 15:14:09.804  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Setting newly assigned partitions [trans-topic-2]
2018-07-12 15:14:09.804 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Fetching committed offsets for partitions: [trans-topic-2]
2018-07-12 15:14:09.804 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Resetting offset for partition trans-topic-2 to the committed offset 69
2018-07-12 15:14:09.804 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Committing on assignment: {trans-topic-2=OffsetAndMetadata{offset=69, metadata=''}}
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Creating new transaction with name [null]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state READY to IN_TRANSACTION
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Created Kafka transaction on producer [brave.kafka.clients.TracingProducer@494a311e]
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Begin adding offsets {trans-topic-2=OffsetAndMetadata{offset=69, metadata=''}} for consumer group mygrp42 to transaction
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Enqueuing transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42)
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.806 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Successfully added partition for consumer group mygrp42 to transaction
2018-07-12 15:14:09.806 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=TxnOffsetCommitRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, consumerGroupId=mygrp42, offsets={trans-topic-2=CommittedOffset(offset=69, metadata='')}) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.807 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Successfully added offsets {trans-topic-2=CommittedOffset(offset=69, metadata='')} from consumer group mygrp42 to transaction.
2018-07-12 15:14:09.807 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Initiating transaction commit
2018-07-12 15:14:09.807 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state IN_TRANSACTION to COMMITTING_TRANSACTION
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Enqueuing transactional request (type=EndTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, result=COMMIT)
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-1, transactionalId=transactionId420] Sending transactional request (type=EndTxnRequest, transactionalId=transactionId420, producerId=0, producerEpoch=99, result=COMMIT) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.809 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ad | producer-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-1, transactionalId=transactionId420] Transition from state COMMITTING_TRANSACTION to READY
2018-07-12 15:14:09.809  INFO [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned: [trans-topic-2]
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 56 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 441 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Ignoring fetched records for partition trans-topic-1 since it is no longer fetchable
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Discarding stale fetch response for partition trans-topic-2 since its offset 70 does not match the expected offset 69
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Ignoring fetched records for partition trans-topic-0 since it is no longer fetchable
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 69 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.847 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.849 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 69 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=78)
2018-07-12 15:14:09.849 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.849 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.220 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
2018-07-12 15:14:10.220 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:10.351 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:10.351 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.351 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.853 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:10.854 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.854 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:11.355 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:11.355 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:11.355 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:11.858 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:11.858 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:11.858 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:12.360 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:12.361 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:12.361 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:12.806 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending Heartbeat request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:12.808 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:14:12.864 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 70 for partition trans-topic-2 returned fetch data (error=NONE, highWaterMark=70, lastStableOffset = -1, logStartOffset = 66, abortedTransactions = null, recordsSizeInBytes=0)
2018-07-12 15:14:12.865 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Added READ_UNCOMMITTED fetch request for partition trans-topic-2 at offset 70 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:12.865 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Sending READ_UNCOMMITTED fetch for partitions [trans-topic-2] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:13.223 DEBUG [kafka-transaction-microservice-example,,,] 59320 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records