API tools faq
paste
m5001

controller.log

m5001
Nov 3rd, 2017
51
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 61.66 KB | None | 0 0
raw download clone embed print report
  1. [2017-11-03 19:44:06,816] (kafka.controller.ControllerEventManager$ControllerEventThread) [controller-event-thread] INFO - [controller-event-thread]: Starting
  2. [2017-11-03 19:44:06,830] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: 0 successfully elected as the controller
  3. [2017-11-03 19:44:06,831] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Broker 0 starting become controller state transition
  4. [2017-11-03 19:44:06,836] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Controller 0 incremented epoch to 1
  5. [2017-11-03 19:44:06,837] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Registering IsrChangeNotificationListener
  6. [2017-11-03 19:44:06,853] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Partitions being reassigned: Map()
  7. [2017-11-03 19:44:06,854] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Partitions already reassigned: Set()
  8. [2017-11-03 19:44:06,855] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Resuming reassignment of partitions: Map()
  9. [2017-11-03 19:44:06,856] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Currently active brokers in the cluster: Set()
  10. [2017-11-03 19:44:06,856] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Currently shutting brokers in the cluster: Set()
  11. [2017-11-03 19:44:06,857] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Current list of topics in the cluster: Set()
  12. [2017-11-03 19:44:06,859] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: List of topics to be deleted:
  13. [2017-11-03 19:44:06,859] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: List of topics ineligible for deletion:
  14. [2017-11-03 19:44:06,870] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Started replica state machine with initial state -> Map()
  15. [2017-11-03 19:44:06,872] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map()
  16. [2017-11-03 19:44:06,873] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1
  17. [2017-11-03 19:44:06,882] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Partitions undergoing preferred replica election:
  18. [2017-11-03 19:44:06,882] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Partitions that completed preferred replica election:
  19. [2017-11-03 19:44:06,882] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Skipping preferred replica election for partitions due to topic deletion:
  20. [2017-11-03 19:44:06,883] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Resuming preferred replica election for partitions:
  21. [2017-11-03 19:44:06,883] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Starting preferred replica leader election for partitions
  22. [2017-11-03 19:44:06,894] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions
  23. [2017-11-03 19:44:06,900] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: starting the controller scheduler
  24. [2017-11-03 19:44:06,942] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0
  25. [2017-11-03 19:44:06,943] (kafka.controller.ControllerChannelManager) [controller-event-thread] DEBUG - [Channel manager on controller 0]: Controller 0 trying to connect to broker 0
  26. [2017-11-03 19:44:06,946] (kafka.controller.RequestSendThread) [Controller-0-to-broker-0-send-thread] INFO - [Controller-0-to-broker-0-send-thread]: Starting
  27. [2017-11-03 19:44:06,947] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New broker startup callback for 0
  28. [2017-11-03 19:44:06,952] (kafka.controller.RequestSendThread) [Controller-0-to-broker-0-send-thread] INFO - [Controller-0-to-broker-0-send-thread]: Controller 0 connected to localhost:9092 (id: 0 rack: null) for sending state change requests
  29. [2017-11-03 19:44:11,906] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Checking need to trigger auto leader balancing
  30. [2017-11-03 19:44:11,909] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Preferred replicas by broker Map()
  31. [2017-11-03 19:44:16,486] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topics: [Set(_schemas)], deleted topics: [Set()], new partition replica assignment [Map([_schemas,0] -> List(0))]
  32. [2017-11-03 19:44:16,486] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topic creation callback for [_schemas,0]
  33. [2017-11-03 19:44:16,488] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New partition creation callback for [_schemas,0]
  34. [2017-11-03 19:44:16,489] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [_schemas,0]
  35. [2017-11-03 19:44:16,491] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=_schemas,Partition=0,Replica=0]
  36. [2017-11-03 19:44:16,495] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [_schemas,0]
  37. [2017-11-03 19:44:16,495] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [_schemas,0] are: [List(0)]
  38. [2017-11-03 19:44:16,497] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [_schemas,0] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  39. [2017-11-03 19:44:16,507] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=_schemas,Partition=0,Replica=0]
  40. [2017-11-03 19:44:40,835] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topics: [Set(test)], deleted topics: [Set()], new partition replica assignment [Map([test,1] -> List(0), [test,2] -> List(0), [test,0] -> List(0))]
  41. [2017-11-03 19:44:40,835] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topic creation callback for [test,1],[test,2],[test,0]
  42. [2017-11-03 19:44:40,836] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New partition creation callback for [test,1],[test,2],[test,0]
  43. [2017-11-03 19:44:40,836] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [test,1],[test,2],[test,0]
  44. [2017-11-03 19:44:40,837] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=test,Partition=1,Replica=0],[Topic=test,Partition=2,Replica=0],[Topic=test,Partition=0,Replica=0]
  45. [2017-11-03 19:44:40,840] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [test,1],[test,2],[test,0]
  46. [2017-11-03 19:44:40,840] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [test,1] are: [List(0)]
  47. [2017-11-03 19:44:40,840] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [test,1] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  48. [2017-11-03 19:44:40,845] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [test,2] are: [List(0)]
  49. [2017-11-03 19:44:40,845] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [test,2] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  50. [2017-11-03 19:44:40,848] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [test,0] are: [List(0)]
  51. [2017-11-03 19:44:40,848] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [test,0] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  52. [2017-11-03 19:44:40,852] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=test,Partition=1,Replica=0],[Topic=test,Partition=2,Replica=0],[Topic=test,Partition=0,Replica=0]
  53. [2017-11-03 19:44:52,305] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0))]
  54. [2017-11-03 19:44:52,306] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New topic creation callback for [__consumer_offsets,19],[__consumer_offsets,30],[__consumer_offsets,47],[__consumer_offsets,29],[__consumer_offsets,41],[__consumer_offsets,39],[__consumer_offsets,10],[__consumer_offsets,17],[__consumer_offsets,14],[__consumer_offsets,40],[__consumer_offsets,18],[__consumer_offsets,26],[__consumer_offsets,0],[__consumer_offsets,24],[__consumer_offsets,33],[__consumer_offsets,20],[__consumer_offsets,21],[__consumer_offsets,3],[__consumer_offsets,5],[__consumer_offsets,22],[__consumer_offsets,12],[__consumer_offsets,8],[__consumer_offsets,23],[__consumer_offsets,15],[__consumer_offsets,48],[__consumer_offsets,11],[__consumer_offsets,13],[__consumer_offsets,49],[__consumer_offsets,6],[__consumer_offsets,28],[__consumer_offsets,4],[__consumer_offsets,37],[__consumer_offsets,31],[__consumer_offsets,44],[__consumer_offsets,42],[__consumer_offsets,34],[__consumer_offsets,46],[__consumer_offsets,25],[__consumer_offsets,45],[__consumer_offsets,27],[__consumer_offsets,32],[__consumer_offsets,43],[__consumer_offsets,36],[__consumer_offsets,35],[__consumer_offsets,7],[__consumer_offsets,9],[__consumer_offsets,38],[__consumer_offsets,1],[__consumer_offsets,16],[__consumer_offsets,2]
  55. [2017-11-03 19:44:52,310] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: New partition creation callback for [__consumer_offsets,19],[__consumer_offsets,30],[__consumer_offsets,47],[__consumer_offsets,29],[__consumer_offsets,41],[__consumer_offsets,39],[__consumer_offsets,10],[__consumer_offsets,17],[__consumer_offsets,14],[__consumer_offsets,40],[__consumer_offsets,18],[__consumer_offsets,26],[__consumer_offsets,0],[__consumer_offsets,24],[__consumer_offsets,33],[__consumer_offsets,20],[__consumer_offsets,21],[__consumer_offsets,3],[__consumer_offsets,5],[__consumer_offsets,22],[__consumer_offsets,12],[__consumer_offsets,8],[__consumer_offsets,23],[__consumer_offsets,15],[__consumer_offsets,48],[__consumer_offsets,11],[__consumer_offsets,13],[__consumer_offsets,49],[__consumer_offsets,6],[__consumer_offsets,28],[__consumer_offsets,4],[__consumer_offsets,37],[__consumer_offsets,31],[__consumer_offsets,44],[__consumer_offsets,42],[__consumer_offsets,34],[__consumer_offsets,46],[__consumer_offsets,25],[__consumer_offsets,45],[__consumer_offsets,27],[__consumer_offsets,32],[__consumer_offsets,43],[__consumer_offsets,36],[__consumer_offsets,35],[__consumer_offsets,7],[__consumer_offsets,9],[__consumer_offsets,38],[__consumer_offsets,1],[__consumer_offsets,16],[__consumer_offsets,2]
  56. [2017-11-03 19:44:52,311] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to NewPartition for partitions [__consumer_offsets,19],[__consumer_offsets,30],[__consumer_offsets,47],[__consumer_offsets,29],[__consumer_offsets,41],[__consumer_offsets,39],[__consumer_offsets,10],[__consumer_offsets,17],[__consumer_offsets,14],[__consumer_offsets,40],[__consumer_offsets,18],[__consumer_offsets,26],[__consumer_offsets,0],[__consumer_offsets,24],[__consumer_offsets,33],[__consumer_offsets,20],[__consumer_offsets,21],[__consumer_offsets,3],[__consumer_offsets,5],[__consumer_offsets,22],[__consumer_offsets,12],[__consumer_offsets,8],[__consumer_offsets,23],[__consumer_offsets,15],[__consumer_offsets,48],[__consumer_offsets,11],[__consumer_offsets,13],[__consumer_offsets,49],[__consumer_offsets,6],[__consumer_offsets,28],[__consumer_offsets,4],[__consumer_offsets,37],[__consumer_offsets,31],[__consumer_offsets,44],[__consumer_offsets,42],[__consumer_offsets,34],[__consumer_offsets,46],[__consumer_offsets,25],[__consumer_offsets,45],[__consumer_offsets,27],[__consumer_offsets,32],[__consumer_offsets,43],[__consumer_offsets,36],[__consumer_offsets,35],[__consumer_offsets,7],[__consumer_offsets,9],[__consumer_offsets,38],[__consumer_offsets,1],[__consumer_offsets,16],[__consumer_offsets,2]
  57. [2017-11-03 19:44:52,321] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to NewReplica for replicas [Topic=__consumer_offsets,Partition=25,Replica=0],[Topic=__consumer_offsets,Partition=12,Replica=0],[Topic=__consumer_offsets,Partition=31,Replica=0],[Topic=__consumer_offsets,Partition=40,Replica=0],[Topic=__consumer_offsets,Partition=35,Replica=0],[Topic=__consumer_offsets,Partition=9,Replica=0],[Topic=__consumer_offsets,Partition=43,Replica=0],[Topic=__consumer_offsets,Partition=2,Replica=0],[Topic=__consumer_offsets,Partition=11,Replica=0],[Topic=__consumer_offsets,Partition=29,Replica=0],[Topic=__consumer_offsets,Partition=30,Replica=0],[Topic=__consumer_offsets,Partition=4,Replica=0],[Topic=__consumer_offsets,Partition=42,Replica=0],[Topic=__consumer_offsets,Partition=26,Replica=0],[Topic=__consumer_offsets,Partition=34,Replica=0],[Topic=__consumer_offsets,Partition=17,Replica=0],[Topic=__consumer_offsets,Partition=37,Replica=0],[Topic=__consumer_offsets,Partition=27,Replica=0],[Topic=__consumer_offsets,Partition=10,Replica=0],[Topic=__consumer_offsets,Partition=41,Replica=0],[Topic=__consumer_offsets,Partition=20,Replica=0],[Topic=__consumer_offsets,Partition=28,Replica=0],[Topic=__consumer_offsets,Partition=46,Replica=0],[Topic=__consumer_offsets,Partition=39,Replica=0],[Topic=__consumer_offsets,Partition=47,Replica=0],[Topic=__consumer_offsets,Partition=49,Replica=0],[Topic=__consumer_offsets,Partition=22,Replica=0],[Topic=__consumer_offsets,Partition=1,Replica=0],[Topic=__consumer_offsets,Partition=24,Replica=0],[Topic=__consumer_offsets,Partition=6,Replica=0],[Topic=__consumer_offsets,Partition=36,Replica=0],[Topic=__consumer_offsets,Partition=8,Replica=0],[Topic=__consumer_offsets,Partition=38,Replica=0],[Topic=__consumer_offsets,Partition=16,Replica=0],[Topic=__consumer_offsets,Partition=21,Replica=0],[Topic=__consumer_offsets,Partition=18,Replica=0],[Topic=__consumer_offsets,Partition=0,Replica=0],[Topic=__consumer_offsets,Partition=48,Replica=0],[Topic=__consumer_offsets,Partition=5,Replica=0],[Topic=__consumer_offsets,Partition=13,Replica=0],[Topic=__consumer_offsets,Partition=3,Replica=0],[Topic=__consumer_offsets,Partition=44,Replica=0],[Topic=__consumer_offsets,Partition=15,Replica=0],[Topic=__consumer_offsets,Partition=7,Replica=0],[Topic=__consumer_offsets,Partition=19,Replica=0],[Topic=__consumer_offsets,Partition=33,Replica=0],[Topic=__consumer_offsets,Partition=45,Replica=0],[Topic=__consumer_offsets,Partition=23,Replica=0],[Topic=__consumer_offsets,Partition=32,Replica=0],[Topic=__consumer_offsets,Partition=14,Replica=0]
  58. [2017-11-03 19:44:52,389] (kafka.controller.PartitionStateMachine) [controller-event-thread] INFO - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions [__consumer_offsets,19],[__consumer_offsets,30],[__consumer_offsets,47],[__consumer_offsets,29],[__consumer_offsets,41],[__consumer_offsets,39],[__consumer_offsets,10],[__consumer_offsets,17],[__consumer_offsets,14],[__consumer_offsets,40],[__consumer_offsets,18],[__consumer_offsets,26],[__consumer_offsets,0],[__consumer_offsets,24],[__consumer_offsets,33],[__consumer_offsets,20],[__consumer_offsets,21],[__consumer_offsets,3],[__consumer_offsets,5],[__consumer_offsets,22],[__consumer_offsets,12],[__consumer_offsets,8],[__consumer_offsets,23],[__consumer_offsets,15],[__consumer_offsets,48],[__consumer_offsets,11],[__consumer_offsets,13],[__consumer_offsets,49],[__consumer_offsets,6],[__consumer_offsets,28],[__consumer_offsets,4],[__consumer_offsets,37],[__consumer_offsets,31],[__consumer_offsets,44],[__consumer_offsets,42],[__consumer_offsets,34],[__consumer_offsets,46],[__consumer_offsets,25],[__consumer_offsets,45],[__consumer_offsets,27],[__consumer_offsets,32],[__consumer_offsets,43],[__consumer_offsets,36],[__consumer_offsets,35],[__consumer_offsets,7],[__consumer_offsets,9],[__consumer_offsets,38],[__consumer_offsets,1],[__consumer_offsets,16],[__consumer_offsets,2]
  59. [2017-11-03 19:44:52,389] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,19] are: [List(0)]
  60. [2017-11-03 19:44:52,389] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,19] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  61. [2017-11-03 19:44:52,406] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,30] are: [List(0)]
  62. [2017-11-03 19:44:52,406] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,30] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  63. [2017-11-03 19:44:52,411] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,47] are: [List(0)]
  64. [2017-11-03 19:44:52,411] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,47] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  65. [2017-11-03 19:44:52,415] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,29] are: [List(0)]
  66. [2017-11-03 19:44:52,415] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,29] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  67. [2017-11-03 19:44:52,419] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,41] are: [List(0)]
  68. [2017-11-03 19:44:52,419] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,41] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  69. [2017-11-03 19:44:52,422] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,39] are: [List(0)]
  70. [2017-11-03 19:44:52,422] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,39] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  71. [2017-11-03 19:44:52,426] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,10] are: [List(0)]
  72. [2017-11-03 19:44:52,426] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,10] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  73. [2017-11-03 19:44:52,429] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,17] are: [List(0)]
  74. [2017-11-03 19:44:52,429] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,17] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  75. [2017-11-03 19:44:52,431] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,14] are: [List(0)]
  76. [2017-11-03 19:44:52,431] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,14] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  77. [2017-11-03 19:44:52,434] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,40] are: [List(0)]
  78. [2017-11-03 19:44:52,434] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,40] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  79. [2017-11-03 19:44:52,438] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,18] are: [List(0)]
  80. [2017-11-03 19:44:52,438] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,18] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  81. [2017-11-03 19:44:52,441] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,26] are: [List(0)]
  82. [2017-11-03 19:44:52,441] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,26] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  83. [2017-11-03 19:44:52,443] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,0] are: [List(0)]
  84. [2017-11-03 19:44:52,444] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,0] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  85. [2017-11-03 19:44:52,446] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,24] are: [List(0)]
  86. [2017-11-03 19:44:52,446] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,24] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  87. [2017-11-03 19:44:52,448] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,33] are: [List(0)]
  88. [2017-11-03 19:44:52,448] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,33] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  89. [2017-11-03 19:44:52,450] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,20] are: [List(0)]
  90. [2017-11-03 19:44:52,450] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,20] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  91. [2017-11-03 19:44:52,456] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,21] are: [List(0)]
  92. [2017-11-03 19:44:52,456] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,21] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  93. [2017-11-03 19:44:52,459] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,3] are: [List(0)]
  94. [2017-11-03 19:44:52,459] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,3] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  95. [2017-11-03 19:44:52,461] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,5] are: [List(0)]
  96. [2017-11-03 19:44:52,461] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,5] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  97. [2017-11-03 19:44:52,464] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,22] are: [List(0)]
  98. [2017-11-03 19:44:52,464] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,22] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  99. [2017-11-03 19:44:52,466] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,12] are: [List(0)]
  100. [2017-11-03 19:44:52,466] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,12] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  101. [2017-11-03 19:44:52,468] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,8] are: [List(0)]
  102. [2017-11-03 19:44:52,468] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,8] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  103. [2017-11-03 19:44:52,470] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,23] are: [List(0)]
  104. [2017-11-03 19:44:52,470] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,23] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  105. [2017-11-03 19:44:52,473] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,15] are: [List(0)]
  106. [2017-11-03 19:44:52,473] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,15] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  107. [2017-11-03 19:44:52,478] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,48] are: [List(0)]
  108. [2017-11-03 19:44:52,478] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,48] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  109. [2017-11-03 19:44:52,480] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,11] are: [List(0)]
  110. [2017-11-03 19:44:52,480] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,11] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  111. [2017-11-03 19:44:52,483] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,13] are: [List(0)]
  112. [2017-11-03 19:44:52,483] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,13] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  113. [2017-11-03 19:44:52,487] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,49] are: [List(0)]
  114. [2017-11-03 19:44:52,487] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,49] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  115. [2017-11-03 19:44:52,489] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,6] are: [List(0)]
  116. [2017-11-03 19:44:52,490] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,6] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  117. [2017-11-03 19:44:52,492] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,28] are: [List(0)]
  118. [2017-11-03 19:44:52,492] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,28] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  119. [2017-11-03 19:44:52,494] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,4] are: [List(0)]
  120. [2017-11-03 19:44:52,494] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,4] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  121. [2017-11-03 19:44:52,496] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,37] are: [List(0)]
  122. [2017-11-03 19:44:52,497] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,37] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  123. [2017-11-03 19:44:52,499] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,31] are: [List(0)]
  124. [2017-11-03 19:44:52,500] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,31] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  125. [2017-11-03 19:44:52,502] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,44] are: [List(0)]
  126. [2017-11-03 19:44:52,502] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,44] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  127. [2017-11-03 19:44:52,504] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,42] are: [List(0)]
  128. [2017-11-03 19:44:52,504] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,42] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  129. [2017-11-03 19:44:52,506] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,34] are: [List(0)]
  130. [2017-11-03 19:44:52,506] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,34] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  131. [2017-11-03 19:44:52,508] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,46] are: [List(0)]
  132. [2017-11-03 19:44:52,508] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,46] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  133. [2017-11-03 19:44:52,509] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,25] are: [List(0)]
  134. [2017-11-03 19:44:52,509] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,25] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  135. [2017-11-03 19:44:52,511] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,45] are: [List(0)]
  136. [2017-11-03 19:44:52,511] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,45] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  137. [2017-11-03 19:44:52,513] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,27] are: [List(0)]
  138. [2017-11-03 19:44:52,513] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,27] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  139. [2017-11-03 19:44:52,515] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,32] are: [List(0)]
  140. [2017-11-03 19:44:52,515] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,32] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  141. [2017-11-03 19:44:52,516] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,43] are: [List(0)]
  142. [2017-11-03 19:44:52,516] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,43] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  143. [2017-11-03 19:44:52,519] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,36] are: [List(0)]
  144. [2017-11-03 19:44:52,519] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,36] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  145. [2017-11-03 19:44:52,521] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,35] are: [List(0)]
  146. [2017-11-03 19:44:52,521] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,35] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  147. [2017-11-03 19:44:52,524] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,7] are: [List(0)]
  148. [2017-11-03 19:44:52,524] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,7] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  149. [2017-11-03 19:44:52,526] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,9] are: [List(0)]
  150. [2017-11-03 19:44:52,526] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,9] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  151. [2017-11-03 19:44:52,528] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,38] are: [List(0)]
  152. [2017-11-03 19:44:52,528] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,38] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  153. [2017-11-03 19:44:52,530] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,1] are: [List(0)]
  154. [2017-11-03 19:44:52,530] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,1] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  155. [2017-11-03 19:44:52,532] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,16] are: [List(0)]
  156. [2017-11-03 19:44:52,532] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,16] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  157. [2017-11-03 19:44:52,534] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Live assigned replicas for partition [__consumer_offsets,2] are: [List(0)]
  158. [2017-11-03 19:44:52,534] (kafka.controller.PartitionStateMachine) [controller-event-thread] DEBUG - [Partition state machine on Controller 0]: Initializing leader and isr for partition [__consumer_offsets,2] to (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  159. [2017-11-03 19:44:52,543] (kafka.controller.ReplicaStateMachine) [controller-event-thread] INFO - [Replica state machine on controller 0]: Invoking state change to OnlineReplica for replicas [Topic=__consumer_offsets,Partition=25,Replica=0],[Topic=__consumer_offsets,Partition=12,Replica=0],[Topic=__consumer_offsets,Partition=31,Replica=0],[Topic=__consumer_offsets,Partition=40,Replica=0],[Topic=__consumer_offsets,Partition=35,Replica=0],[Topic=__consumer_offsets,Partition=9,Replica=0],[Topic=__consumer_offsets,Partition=43,Replica=0],[Topic=__consumer_offsets,Partition=2,Replica=0],[Topic=__consumer_offsets,Partition=11,Replica=0],[Topic=__consumer_offsets,Partition=29,Replica=0],[Topic=__consumer_offsets,Partition=30,Replica=0],[Topic=__consumer_offsets,Partition=4,Replica=0],[Topic=__consumer_offsets,Partition=42,Replica=0],[Topic=__consumer_offsets,Partition=26,Replica=0],[Topic=__consumer_offsets,Partition=34,Replica=0],[Topic=__consumer_offsets,Partition=17,Replica=0],[Topic=__consumer_offsets,Partition=37,Replica=0],[Topic=__consumer_offsets,Partition=27,Replica=0],[Topic=__consumer_offsets,Partition=10,Replica=0],[Topic=__consumer_offsets,Partition=41,Replica=0],[Topic=__consumer_offsets,Partition=20,Replica=0],[Topic=__consumer_offsets,Partition=28,Replica=0],[Topic=__consumer_offsets,Partition=46,Replica=0],[Topic=__consumer_offsets,Partition=39,Replica=0],[Topic=__consumer_offsets,Partition=47,Replica=0],[Topic=__consumer_offsets,Partition=49,Replica=0],[Topic=__consumer_offsets,Partition=22,Replica=0],[Topic=__consumer_offsets,Partition=1,Replica=0],[Topic=__consumer_offsets,Partition=24,Replica=0],[Topic=__consumer_offsets,Partition=6,Replica=0],[Topic=__consumer_offsets,Partition=36,Replica=0],[Topic=__consumer_offsets,Partition=8,Replica=0],[Topic=__consumer_offsets,Partition=38,Replica=0],[Topic=__consumer_offsets,Partition=16,Replica=0],[Topic=__consumer_offsets,Partition=21,Replica=0],[Topic=__consumer_offsets,Partition=18,Replica=0],[Topic=__consumer_offsets,Partition=0,Replica=0],[Topic=__consumer_offsets,Partition=48,Replica=0],[Topic=__consumer_offsets,Partition=5,Replica=0],[Topic=__consumer_offsets,Partition=13,Replica=0],[Topic=__consumer_offsets,Partition=3,Replica=0],[Topic=__consumer_offsets,Partition=44,Replica=0],[Topic=__consumer_offsets,Partition=15,Replica=0],[Topic=__consumer_offsets,Partition=7,Replica=0],[Topic=__consumer_offsets,Partition=19,Replica=0],[Topic=__consumer_offsets,Partition=33,Replica=0],[Topic=__consumer_offsets,Partition=45,Replica=0],[Topic=__consumer_offsets,Partition=23,Replica=0],[Topic=__consumer_offsets,Partition=32,Replica=0],[Topic=__consumer_offsets,Partition=14,Replica=0]
  160. [2017-11-03 19:49:11,900] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Checking need to trigger auto leader balancing
  161. [2017-11-03 19:49:11,901] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Preferred replicas by broker Map(0 -> Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [test,1] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [test,2] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [_schemas,0] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [test,0] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0)))
  162. [2017-11-03 19:49:11,904] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Topics not in preferred replica Map()
  163. [2017-11-03 19:49:11,904] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Leader imbalance ratio for broker 0 is 0.0
  164. [2017-11-03 19:54:11,895] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Checking need to trigger auto leader balancing
  165. [2017-11-03 19:54:11,896] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Preferred replicas by broker Map(0 -> Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [test,1] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [test,2] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [_schemas,0] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [test,0] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0)))
  166. [2017-11-03 19:54:11,896] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Topics not in preferred replica Map()
  167. [2017-11-03 19:54:11,896] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Leader imbalance ratio for broker 0 is 0.0
  168. [2017-11-03 19:59:11,887] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Checking need to trigger auto leader balancing
  169. [2017-11-03 19:59:11,888] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Preferred replicas by broker Map(0 -> Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [test,1] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [test,2] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [_schemas,0] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [test,0] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0)))
  170. [2017-11-03 19:59:11,889] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Topics not in preferred replica Map()
  171. [2017-11-03 19:59:11,889] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Leader imbalance ratio for broker 0 is 0.0
  172. [2017-11-03 20:04:11,883] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Checking need to trigger auto leader balancing
  173. [2017-11-03 20:04:11,884] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Preferred replicas by broker Map(0 -> Map([__consumer_offsets,19] -> List(0), [__consumer_offsets,30] -> List(0), [__consumer_offsets,47] -> List(0), [__consumer_offsets,29] -> List(0), [__consumer_offsets,41] -> List(0), [test,1] -> List(0), [__consumer_offsets,39] -> List(0), [__consumer_offsets,10] -> List(0), [__consumer_offsets,17] -> List(0), [__consumer_offsets,14] -> List(0), [__consumer_offsets,40] -> List(0), [__consumer_offsets,18] -> List(0), [__consumer_offsets,26] -> List(0), [__consumer_offsets,0] -> List(0), [__consumer_offsets,24] -> List(0), [__consumer_offsets,33] -> List(0), [__consumer_offsets,20] -> List(0), [test,2] -> List(0), [__consumer_offsets,21] -> List(0), [__consumer_offsets,3] -> List(0), [__consumer_offsets,5] -> List(0), [__consumer_offsets,22] -> List(0), [__consumer_offsets,12] -> List(0), [__consumer_offsets,8] -> List(0), [__consumer_offsets,23] -> List(0), [__consumer_offsets,15] -> List(0), [__consumer_offsets,48] -> List(0), [__consumer_offsets,11] -> List(0), [__consumer_offsets,13] -> List(0), [__consumer_offsets,49] -> List(0), [__consumer_offsets,6] -> List(0), [__consumer_offsets,28] -> List(0), [__consumer_offsets,4] -> List(0), [_schemas,0] -> List(0), [__consumer_offsets,37] -> List(0), [__consumer_offsets,31] -> List(0), [__consumer_offsets,44] -> List(0), [__consumer_offsets,42] -> List(0), [__consumer_offsets,34] -> List(0), [__consumer_offsets,46] -> List(0), [__consumer_offsets,25] -> List(0), [__consumer_offsets,45] -> List(0), [__consumer_offsets,27] -> List(0), [__consumer_offsets,32] -> List(0), [__consumer_offsets,43] -> List(0), [__consumer_offsets,36] -> List(0), [__consumer_offsets,35] -> List(0), [__consumer_offsets,7] -> List(0), [test,0] -> List(0), [__consumer_offsets,9] -> List(0), [__consumer_offsets,38] -> List(0), [__consumer_offsets,1] -> List(0), [__consumer_offsets,16] -> List(0), [__consumer_offsets,2] -> List(0)))
  174. [2017-11-03 20:04:11,884] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Topics not in preferred replica Map()
  175. [2017-11-03 20:04:11,884] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: Leader imbalance ratio for broker 0 is 0.0
  176. [2017-11-03 20:04:38,911] (kafka.controller.KafkaController) [controller-event-thread] INFO - [Controller 0]: Shutting down broker 0
  177. [2017-11-03 20:04:38,911] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: All shutting down brokers: 0
  178. [2017-11-03 20:04:38,912] (kafka.controller.KafkaController) [controller-event-thread] DEBUG - [Controller 0]: Live brokers:
  179. [2017-11-03 20:04:38,914] (kafka.controller.KafkaController) [controller-event-thread] TRACE - [Controller 0]: All leaders = [__consumer_offsets,19] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,30] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,47] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,29] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,41] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[test,1] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,39] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,10] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,17] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,14] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,40] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,18] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,0] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,26] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,24] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,33] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,20] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[test,2] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,3] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,21] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,22] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,5] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,12] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,8] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,23] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,15] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,48] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,11] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,13] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,49] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,6] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,28] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,4] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[_schemas,0] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,37] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,31] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,44] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,42] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,34] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,46] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,25] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,45] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,27] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,32] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,43] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,36] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,35] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,7] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[test,0] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,38] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,9] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,1] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,2] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1),[__consumer_offsets,16] -> (Leader:0,ISR:0,LeaderEpoch:0,ControllerEpoch:1)
  180. [2017-11-03 20:04:42,524] (kafka.controller.ControllerEventManager$ControllerEventThread) [kafka-shutdown-hook] INFO - [controller-event-thread]: Shutting down
  181. [2017-11-03 20:04:42,524] (kafka.controller.ControllerEventManager$ControllerEventThread) [controller-event-thread] INFO - [controller-event-thread]: Stopped
  182. [2017-11-03 20:04:42,524] (kafka.controller.ControllerEventManager$ControllerEventThread) [kafka-shutdown-hook] INFO - [controller-event-thread]: Shutdown completed
  183. [2017-11-03 20:04:42,524] (kafka.controller.KafkaController) [kafka-shutdown-hook] DEBUG - [Controller 0]: Controller resigning, broker id 0
  184. [2017-11-03 20:04:42,524] (kafka.controller.KafkaController) [kafka-shutdown-hook] DEBUG - [Controller 0]: De-registering IsrChangeNotificationListener
  185. [2017-11-03 20:04:42,525] (kafka.controller.PartitionStateMachine) [kafka-shutdown-hook] INFO - [Partition state machine on Controller 0]: Stopped partition state machine
  186. [2017-11-03 20:04:42,526] (kafka.controller.ReplicaStateMachine) [kafka-shutdown-hook] INFO - [Replica state machine on controller 0]: Stopped replica state machine
  187. [2017-11-03 20:04:42,526] (kafka.controller.RequestSendThread) [kafka-shutdown-hook] INFO - [Controller-0-to-broker-0-send-thread]: Shutting down
  188. [2017-11-03 20:04:42,526] (kafka.controller.RequestSendThread) [Controller-0-to-broker-0-send-thread] INFO - [Controller-0-to-broker-0-send-thread]: Stopped
  189. [2017-11-03 20:04:42,526] (kafka.controller.RequestSendThread) [kafka-shutdown-hook] INFO - [Controller-0-to-broker-0-send-thread]: Shutdown completed
  190. [2017-11-03 20:04:42,527] (kafka.controller.KafkaController) [kafka-shutdown-hook] INFO - [Controller 0]: Broker 0 resigned as the controller
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!