[2017-11-06 18:32:53,315] DEBUG Accepted connection from /127.0.0.1:61216 on /127.0.0.1:9092 and assigned it to processor 0, sendBufferSize [actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]: [1048576|1048576] (kafka.network.Acceptor)
[2017-11-06 18:32:53,315] DEBUG Accepted connection from /127.0.0.1:61216 on /127.0.0.1:9092 and assigned it to processor 0, sendBufferSize [actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]: [1048576|1048576] (kafka.network.Acceptor)
[2017-11-06 18:32:53,315] DEBUG Processor 0 listening to new connection from /127.0.0.1:61216 (kafka.network.Processor)
[2017-11-06 18:32:53,315] DEBUG Processor 0 listening to new connection from /127.0.0.1:61216 (kafka.network.Processor)
[2017-11-06 18:32:53,442] DEBUG Accepted connection from /192.168.10.73:61217 on /192.168.10.73:9092 and assigned it to processor 1, sendBufferSize [actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]: [1048576|1048576] (kafka.network.Acceptor)
[2017-11-06 18:32:53,442] DEBUG Accepted connection from /192.168.10.73:61217 on /192.168.10.73:9092 and assigned it to processor 1, sendBufferSize [actual|requested]: [1048576|1048576] recvBufferSize [actual|requested]: [1048576|1048576] (kafka.network.Acceptor)
[2017-11-06 18:32:53,443] DEBUG Processor 1 listening to new connection from /192.168.10.73:61217 (kafka.network.Processor)
[2017-11-06 18:32:53,443] DEBUG Processor 1 listening to new connection from /192.168.10.73:61217 (kafka.network.Processor)
[2017-11-06 18:32:53,545] DEBUG TransactionalId my-Txn-Id prepare transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,545] DEBUG TransactionalId my-Txn-Id prepare transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,546] INFO Updated PartitionLeaderEpoch. New: {epoch:3, offset:3}, Current: {epoch:1, offset0} for Partition: __transaction_state-37. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2017-11-06 18:32:53,546] INFO Updated PartitionLeaderEpoch. New: {epoch:3, offset:3}, Current: {epoch:1, offset0} for Partition: __transaction_state-37. Cache now contains 1 entries. (kafka.server.epoch.LeaderEpochFileCache)
[2017-11-06 18:32:53,549] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,549] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,549] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 4 [0 : 514] (kafka.cluster.Partition)
[2017-11-06 18:32:53,549] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 4 [0 : 514] (kafka.cluster.Partition)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Produce to local log in 5 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG [Replica Manager on Broker 0]: Produce to local log in 5 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,550] DEBUG TransactionalId my-Txn-Id complete transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,550] DEBUG TransactionalId my-Txn-Id complete transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,550] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:53,550] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Empty, topicPartitions=Set(), txnStartTimestamp=-1, txnLastUpdateTimestamp=1509973373545) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:53,551] INFO [Transaction Coordinator 0]: Initialized transactionalId my-Txn-Id with producerId 3004 and producer epoch 0 on partition __transaction_state-37 (kafka.coordinator.transaction.TransactionCoordinator)
[2017-11-06 18:32:53,551] INFO [Transaction Coordinator 0]: Initialized transactionalId my-Txn-Id with producerId 3004 and producer epoch 0 on partition __transaction_state-37 (kafka.coordinator.transaction.TransactionCoordinator)
[2017-11-06 18:32:53,638] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:53,638] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:53,690] DEBUG TransactionalId my-Txn-Id prepare transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,690] DEBUG TransactionalId my-Txn-Id prepare transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 5 [0 : 659] (kafka.cluster.Partition)
[2017-11-06 18:32:53,691] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 5 [0 : 659] (kafka.cluster.Partition)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,691] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,692] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,692] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,692] DEBUG TransactionalId my-Txn-Id complete transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,692] DEBUG TransactionalId my-Txn-Id complete transition from Empty to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:53,692] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:53,692] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=Ongoing, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973373689) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:53,704] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,704] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,704] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 56 [0 : 4928] (kafka.cluster.Partition)
[2017-11-06 18:32:53,704] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 56 [0 : 4928] (kafka.cluster.Partition)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,705] DEBUG [Replica Manager on Broker 0]: Produce to local log in 2 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:53,982] DEBUG Processing request:: sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:53,982] DEBUG sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:53,982] DEBUG Got ping response for sessionid: 0x15f91540dc80000 after 0ms (org.apache.zookeeper.ClientCnxn)
[2017-11-06 18:32:54,189] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,189] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 57 [0 : 5016] (kafka.cluster.Partition)
[2017-11-06 18:32:54,190] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 57 [0 : 5016] (kafka.cluster.Partition)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,190] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,689] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,689] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 58 [0 : 5104] (kafka.cluster.Partition)
[2017-11-06 18:32:54,690] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 58 [0 : 5104] (kafka.cluster.Partition)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:54,690] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,190] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,190] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 59 [0 : 5192] (kafka.cluster.Partition)
[2017-11-06 18:32:55,190] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 59 [0 : 5192] (kafka.cluster.Partition)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,191] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,690] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,690] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 60 [0 : 5280] (kafka.cluster.Partition)
[2017-11-06 18:32:55,690] DEBUG Partition [TopRatedContent2,0] on broker 0: High watermark updated to 60 [0 : 5280] (kafka.cluster.Partition)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Request key TopRatedContent2-0 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,691] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:55,982] DEBUG Processing request:: sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:55,982] DEBUG sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:55,982] DEBUG Got ping response for sessionid: 0x15f91540dc80000 after 0ms (org.apache.zookeeper.ClientCnxn)
[2017-11-06 18:32:56,190] DEBUG TransactionalId my-Txn-Id prepare transition from Ongoing to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,190] DEBUG TransactionalId my-Txn-Id prepare transition from Ongoing to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,191] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,191] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:56,191] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,191] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 6 [0 : 804] (kafka.cluster.Partition)
[2017-11-06 18:32:56,191] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:56,191] DEBUG Partition [__transaction_state,37] on broker 0: High watermark updated to 6 [0 : 804] (kafka.cluster.Partition)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 fetch requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 producer requests. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Request key __transaction_state-37 unblocked 0 DeleteRecordsRequest. (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:56,192] DEBUG [Replica Manager on Broker 0]: Produce to local log in 1 ms (kafka.server.ReplicaManager)
[2017-11-06 18:32:56,192] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[2017-11-06 18:32:56,192] DEBUG TransactionalId my-Txn-Id complete transition from Ongoing to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,192] DEBUG TransactionalId my-Txn-Id complete transition from Ongoing to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,192] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:56,192] DEBUG [Transaction State Manager 0]: Updating my-Txn-Id's transaction state to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=PrepareCommit, topicPartitions=Set(TopRatedContent2-0), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376190) with coordinator epoch 2 for my-Txn-Id succeeded (kafka.coordinator.transaction.TransactionStateManager)
[2017-11-06 18:32:56,193] DEBUG TransactionalId my-Txn-Id prepare transition from PrepareCommit to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376192) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,193] DEBUG TransactionalId my-Txn-Id prepare transition from PrepareCommit to TxnTransitMetadata(producerId=3004, producerEpoch=0, txnTimeoutMs=60000, txnState=CompleteCommit, topicPartitions=Set(), txnStartTimestamp=1509973373689, txnLastUpdateTimestamp=1509973376192) (kafka.coordinator.transaction.TransactionMetadata)
[2017-11-06 18:32:56,194] DEBUG Connection with /192.168.10.73 disconnected (org.apache.kafka.common.network.Selector)
java.io.EOFException
	at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:87)
	at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:75)
	at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:203)
	at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:167)
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:381)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:326)
	at kafka.network.Processor.poll(SocketServer.scala:500)
	at kafka.network.Processor.run(SocketServer.scala:435)
	at java.lang.Thread.run(Thread.java:748)
[2017-11-06 18:32:56,194] DEBUG Connection with /127.0.0.1 disconnected (org.apache.kafka.common.network.Selector)
java.io.EOFException
	at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:87)
	at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:75)
	at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:203)
	at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:167)
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:381)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:326)
	at kafka.network.Processor.poll(SocketServer.scala:500)
	at kafka.network.Processor.run(SocketServer.scala:435)
	at java.lang.Thread.run(Thread.java:748)
[2017-11-06 18:32:57,983] DEBUG Processing request:: sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:57,983] DEBUG sessionid:0x15f91540dc80000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a (org.apache.zookeeper.server.FinalRequestProcessor)
[2017-11-06 18:32:57,983] DEBUG Got ping response for sessionid: 0x15f91540dc80000 after 0ms (org.apache.zookeeper.ClientCnxn)
[2017-11-06 18:32:58,041] DEBUG Searching offset for timestamp -2 (kafka.log.Log)
[