[2018-04-20 11:54:52,055] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218092054) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,086] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218092054) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,088] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218092054) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:52,089] INFO [TransactionCoordinator id=2] Initialized transactionalId demo-service0.5-0_0 with producerId 2000 and producer epoch 0 on partition __transaction_state-8 (kafka.coordinator.transaction.TransactionCoordinator)
[2018-04-20 11:54:52,434] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092433) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,451] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092433) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,451] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092433) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:52,597] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092597) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,608] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092597) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,608] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092597) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:52,831] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092831) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,845] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092831) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,845] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092831) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:52,926] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092926) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,940] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092926) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:52,940] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218092926) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:53,207] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093207) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:53,216] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093207) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:53,216] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093207) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:54:53,218] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093218) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:53,281] DEBUG [Transaction Marker Channel Manager 2]: Sending demo-service0.5-0_0's transaction markers for TransactionMetadata(transactionalId=demo-service0.5-0_0, producerId=2000, producerEpoch=0, txnTimeoutMs=60000, state=PrepareCommit, pendingState=Some(CompleteCommit), topicPartitions=Set(), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093207) with coordinator epoch 0 succeeded, trying to append complete transaction log now (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2018-04-20 11:54:53,315] DEBUG TransactionalId demo-service0.5-0_0 complete transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093218) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:54:53,315] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218092433, txnLastUpdateTimestamp=1524218093218) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:24,810] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124810) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,818] DEBUG TransactionalId demo-service0.5-0_0 complete transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124810) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,818] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124810) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:24,842] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124842) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,852] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124842) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,852] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124842) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:24,876] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124876) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,885] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124876) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,885] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124876) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:24,973] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124973) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,981] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124973) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:24,982] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124973) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:24,997] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124997) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:25,005] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124997) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:25,005] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(demos-succeeded-0, __consumer_offsets-36, demo-service0.5-events-processed-changelog-0, demo-service0.5-demos-state-changelog-0), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124997) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:55:25,005] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218125005) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:25,024] DEBUG [Transaction Marker Channel Manager 2]: Sending demo-service0.5-0_0's transaction markers for TransactionMetadata(transactionalId=demo-service0.5-0_0, producerId=2000, producerEpoch=0, txnTimeoutMs=60000, state=PrepareCommit, pendingState=Some(CompleteCommit), topicPartitions=Set(), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218124997) with coordinator epoch 0 succeeded, trying to append complete transaction log now (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2018-04-20 11:55:25,033] DEBUG TransactionalId demo-service0.5-0_0 complete transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218125005) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:55:25,033] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218124810, txnLastUpdateTimestamp=1524218125005) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:57:52,377] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218272377) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:57:52,383] DEBUG TransactionalId demo-service0.5-0_0 complete transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218272377) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:57:52,383] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218272377) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:59:24,367] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=PrepareEpochFence, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218272377) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:59:24,367] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364367) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:59:24,373] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364367) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:59:24,373] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364367) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:59:24,373] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from PrepareAbort to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364373) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:59:24,374] INFO [TransactionCoordinator id=2] Completed rollback ongoing transaction of transactionalId: demo-service0.5-0_0 due to timeout (kafka.coordinator.transaction.TransactionCoordinator)
[2018-04-20 11:59:24,385] DEBUG [Transaction Marker Channel Manager 2]: Sending demo-service0.5-0_0's transaction markers for TransactionMetadata(transactionalId=demo-service0.5-0_0, producerId=2000, producerEpoch=1, txnTimeoutMs=60000, state=PrepareAbort, pendingState=Some(CompleteAbort), topicPartitions=Set(), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364367) with coordinator epoch 0 succeeded, trying to append complete transaction log now (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2018-04-20 11:59:24,390] DEBUG TransactionalId demo-service0.5-0_0 complete transition from PrepareAbort to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364373) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 11:59:24,390] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=1, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218272377, txnLastUpdateTimestamp=1524218364373) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 11:59:48,322] DEBUG [TransactionCoordinator id=2] Returning INVALID_PRODUCER_EPOCH error code to client for demo-service0.5-0_0's AddPartitions request (kafka.coordinator.transaction.TransactionCoordinator)
[2018-04-20 12:02:18,443] INFO [GroupCoordinator 2]: Member demo-service0.5-0cf7c63c-0e47-4c70-9327-71687f35e794-StreamThread-1-consumer-0edc4b4f-61f6-471d-a386-d135dcc229ec in group demo-service0.5 has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2018-04-20 12:02:27,808] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from CompleteAbort to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218547808) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:27,815] DEBUG TransactionalId demo-service0.5-0_0 complete transition from CompleteAbort to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218547808) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:27,815] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1524218547808) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:02:27,815] INFO [TransactionCoordinator id=2] Initialized transactionalId demo-service0.5-0_0 with producerId 2000 and producer epoch 2 on partition __transaction_state-8 (kafka.coordinator.transaction.TransactionCoordinator)
[2018-04-20 12:02:29,020] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549020) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,026] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Empty to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549020) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,026] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549020) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:02:29,247] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549247) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,259] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549247) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,259] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(__consumer_offsets-36), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549247) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:02:29,259] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549259) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,265] DEBUG [Transaction Marker Channel Manager 2]: Sending demo-service0.5-0_0's transaction markers for TransactionMetadata(transactionalId=demo-service0.5-0_0, producerId=2000, producerEpoch=2, txnTimeoutMs=60000, state=PrepareCommit, pendingState=Some(CompleteCommit), topicPartitions=Set(), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549247) with coordinator epoch 0 succeeded, trying to append complete transaction log now (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2018-04-20 12:02:29,270] DEBUG TransactionalId demo-service0.5-0_0 complete transition from PrepareCommit to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549259) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:02:29,270] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1524218549020, txnLastUpdateTimestamp=1524218549259) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:05:28,980] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218728980) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:05:28,987] DEBUG TransactionalId demo-service0.5-0_0 complete transition from CompleteCommit to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218728980) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:05:28,987] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=2, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218728980) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:07:24,384] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=PrepareEpochFence, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218728980) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:07:24,384] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844384) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:07:24,391] DEBUG TransactionalId demo-service0.5-0_0 complete transition from Ongoing to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844384) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:07:24,391] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=PrepareAbort, topicPartitions=Set(demo-service0.5-events-processed-changelog-0), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844384) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2018-04-20 12:07:24,391] DEBUG TransactionalId demo-service0.5-0_0 prepare transition from PrepareAbort to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844391) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:07:24,391] INFO [TransactionCoordinator id=2] Completed rollback ongoing transaction of transactionalId: demo-service0.5-0_0 due to timeout (kafka.coordinator.transaction.TransactionCoordinator)
[2018-04-20 12:07:24,397] DEBUG [Transaction Marker Channel Manager 2]: Sending demo-service0.5-0_0's transaction markers for TransactionMetadata(transactionalId=demo-service0.5-0_0, producerId=2000, producerEpoch=3, txnTimeoutMs=60000, state=PrepareAbort, pendingState=Some(CompleteAbort), topicPartitions=Set(), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844384) with coordinator epoch 0 succeeded, trying to append complete transaction log now (kafka.coordinator.transaction.TransactionMarkerChannelManager)
[2018-04-20 12:07:24,401] DEBUG TransactionalId demo-service0.5-0_0 complete transition from PrepareAbort to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844391) (kafka.coordinator.transaction.TransactionMetadata)
[2018-04-20 12:07:24,401] DEBUG [Transaction State Manager 2]: Updating demo-service0.5-0_0's transaction state to TxnTransitMetadata(producerId=2000, producerEpoch=3, txnTimeoutMs=60000, txnState=CompleteAbort, topicPartitions=Set(), txnStartTimestamp=1524218728980, txnLastUpdateTimestamp=1524218844391) with coordinator epoch 0 for demo-service0.5-0_0 succeeded (kafka.coordinator.transaction.TransactionStateManager)