2018-07-12 15:13:38.045 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 1 records
2018-07-12 15:13:38.045 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:38.045 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state READY to IN_TRANSACTION
2018-07-12 15:13:38.045 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Created Kafka transaction on producer [brave.kafka.clients.TracingProducer@7651951f]
2018-07-12 15:13:38.045 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] l.a.BatchMessagingMessageListenerAdapter : Processing [GenericMessage [payload=[data], headers={kafka_offset=[439], kafka_consumer=brave.kafka.clients.TracingConsumer@3e28092e, kafka_timestampType=[CREATE_TIME], kafka_receivedMessageKey=[null], kafka_receivedPartitionId=[0], kafka_receivedTopic=[trans-topic], kafka_receivedTimestamp=[1531397618039], kafka_batchConvertedHeaders=[{X-B3-SpanId=[B@2e9a96e3, X-B3-ParentSpanId=[B@6987c0bb, X-B3-Sampled=[B@7e6c34b, X-B3-TraceId=[B@7de557c5}]}]]
2018-07-12 15:13:38.146 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] 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:38.147 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 440 for partition trans-topic-0 returned fetch data (error=NONE, highWaterMark=441, lastStableOffset = -1, logStartOffset = 435, abortedTransactions = null, recordsSizeInBytes=78)
2018-07-12 15:13:39.791 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:39.896 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:42.887 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:42.990 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:45.889 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:45.994 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Received successful Heartbeat response
2018-07-12 15:13:46.530 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [n(13)-127.0.0.1] sun.rmi.transport.tcp                    : RMI TCP Connection(13)-127.0.0.1: (port 52483) connection closed
2018-07-12 15:13:46.530 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [n(13)-127.0.0.1] sun.rmi.transport.tcp                    : RMI TCP Connection(13)-127.0.0.1: close connection
2018-07-12 15:13:47.643 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending LeaveGroup request to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:13:47.644 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [hread | mygrp42] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Disabling heartbeat thread
2018-07-12 15:13:53.766 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [l-1 housekeeper] com.zaxxer.hikari.pool.HikariPool        : HikariPool-1 - Pool stats (total=10, active=0, idle=10, waiting=0)
2018-07-12 15:14:08.228 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Sending offsets to transaction: {trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}}
2018-07-12 15:14:08.228 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Begin adding offsets {trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}} for consumer group mygrp42 to transaction
2018-07-12 15:14:08.229 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Enqueuing transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42)
2018-07-12 15:14:08.229 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.231 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Successfully added partition for consumer group mygrp42 to transaction
2018-07-12 15:14:08.231 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=TxnOffsetCommitRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42, offsets={trans-topic-0=CommittedOffset(offset=440, metadata='')}) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.232 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Successfully added offsets {trans-topic-0=CommittedOffset(offset=440, metadata='')} from consumer group mygrp42 to transaction.
2018-07-12 15:14:08.232 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Initiating transaction commit
2018-07-12 15:14:08.233 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state IN_TRANSACTION to COMMITTING_TRANSACTION
2018-07-12 15:14:08.233 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Enqueuing transactional request (type=EndTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, result=COMMIT)
2018-07-12 15:14:08.233 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=EndTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, result=COMMIT) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state COMMITTING_TRANSACTION to READY
2018-07-12 15:14:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:08.234  INFO [kafka-transaction-microservice-example,,,] 59313 --- [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]
2018-07-12 15:14:08.234  INFO [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : partitions revoked: [trans-topic-1, trans-topic-0]
2018-07-12 15:14:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
2018-07-12 15:14:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:08.234  INFO [kafka-transaction-microservice-example,,,] 59313 --- [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:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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=, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@7b2eb14)) to coordinator localhost:9092 (id: 2147483647 rack: null)
2018-07-12 15:14:08.234 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] LeaveGroup request returned successfully
2018-07-12 15:14:09.801 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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@50e76141
2018-07-12 15:14:09.802 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Sending follower SyncGroup to coordinator localhost:9092 (id: 2147483647 rack: null): (type=SyncGroupRequest, groupId=mygrp42, generationId=313, memberId=consumer-1-3dcfe3d4-3c0d-42d6-8079-1f6a63d0e283, groupAssignment=)
2018-07-12 15:14:09.803  INFO [kafka-transaction-microservice-example,,,] 59313 --- [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,,,] 59313 --- [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  INFO [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator  : [Consumer clientId=consumer-1, groupId=mygrp42] Setting newly assigned partitions [trans-topic-1, trans-topic-0]
2018-07-12 15:14:09.803 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-1, trans-topic-0]
2018-07-12 15:14:09.804 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Resetting offset for partition trans-topic-1 to the committed offset 55
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Resetting offset for partition trans-topic-0 to the committed offset 440
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Committing on assignment: {trans-topic-1=OffsetAndMetadata{offset=55, metadata=''}, trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}}
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state READY to IN_TRANSACTION
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Created Kafka transaction on producer [brave.kafka.clients.TracingProducer@612a0c8d]
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Begin adding offsets {trans-topic-1=OffsetAndMetadata{offset=55, metadata=''}, trans-topic-0=OffsetAndMetadata{offset=440, metadata=''}} for consumer group mygrp42 to transaction
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Enqueuing transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42)
2018-07-12 15:14:09.805 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=AddOffsetsToTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.806 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Successfully added partition for consumer group mygrp42 to transaction
2018-07-12 15:14:09.807 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=TxnOffsetCommitRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, consumerGroupId=mygrp42, offsets={trans-topic-1=CommittedOffset(offset=55, metadata=''), trans-topic-0=CommittedOffset(offset=440, metadata='')}) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Successfully added offsets {trans-topic-1=CommittedOffset(offset=55, metadata=''), trans-topic-0=CommittedOffset(offset=440, metadata='')} from consumer group mygrp42 to transaction.
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Successfully added offsets {trans-topic-0=CommittedOffset(offset=440, metadata='')} from consumer group mygrp42 to transaction.
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.t.KafkaTransactionManager          : Initiating transaction commit
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state IN_TRANSACTION to COMMITTING_TRANSACTION
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Enqueuing transactional request (type=EndTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, result=COMMIT)
2018-07-12 15:14:09.808 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.clients.producer.internals.Sender  : [Producer clientId=producer-2, transactionalId=transactionId421] Sending transactional request (type=EndTxnRequest, transactionalId=transactionId421, producerId=1, producerEpoch=23, result=COMMIT) to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.809 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ad | producer-2] o.a.k.c.p.internals.TransactionManager   : [Producer clientId=producer-2, transactionalId=transactionId421] Transition from state COMMITTING_TRANSACTION to READY
2018-07-12 15:14:09.809  INFO [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : partitions assigned: [trans-topic-1, trans-topic-0]
2018-07-12 15:14:09.809 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-1 since its offset 56 does not match the expected offset 55
2018-07-12 15:14:09.809 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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 55 to node localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.809 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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.809 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:09.815 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] o.a.k.c.consumer.internals.Fetcher       : [Consumer clientId=consumer-1, groupId=mygrp42] Fetch READ_UNCOMMITTED at offset 55 for partition trans-topic-1 returned fetch data (error=NONE, highWaterMark=56, lastStableOffset = -1, logStartOffset = 54, abortedTransactions = null, recordsSizeInBytes=78)
2018-07-12 15:14:09.815 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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.815 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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.815 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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.815 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.321 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.322 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.322 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.322 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.322 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:10.825 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.825 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.825 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.825 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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:10.825 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [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-0] to broker localhost:9092 (id: 0 rack: null)
2018-07-12 15:14:11.237 DEBUG [kafka-transaction-microservice-example,,,] 59313 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records