[2019-07-10 04:40:40,316] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:40,319] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,319] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,319] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,320] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,320] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,321] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,323] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,323] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,324] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,325] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,325] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,325] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,325] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,326] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,326] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,326] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,326] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,327] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,327] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,329] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,329] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,531] INFO [Controller id=0] New topics: [Set(bar)], deleted topics: [Set()], new partition replica assignment [Map(bar-1 -> Vector(0), bar-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:40,532] INFO [Controller id=0] New partition creation callback for bar-1,bar-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:41,037] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:41,037] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:45,328] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:40:46,910] INFO [Controller id=0] Starting topic deletion for topics bar (kafka.controller.KafkaController:66)
[2019-07-10 04:40:48,025] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:48,026] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:48,026] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:48,028] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,377] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:50,381] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,381] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,382] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,382] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,383] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,384] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,387] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,388] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,388] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,388] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,388] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,389] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,389] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,389] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,389] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,390] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,390] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,390] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,391] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,391] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,391] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,391] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,391] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,392] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,394] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,394] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,681] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:50,682] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:55,393] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:40:57,328] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:57,329] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:57,329] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:57,330] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,438] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:40:58,445] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,445] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,446] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,446] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,447] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,448] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,450] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,451] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,452] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,452] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,452] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,452] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,452] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,453] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,453] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,453] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,454] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,454] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,454] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,456] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,456] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,752] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:40:58,753] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:03,455] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:41:06,052] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:06,053] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:06,053] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:06,054] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,486] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:07,490] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,490] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,490] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,491] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,491] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,492] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,494] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,494] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,495] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,496] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,496] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,496] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,496] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,497] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,497] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,497] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,497] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,498] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,498] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,499] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,500] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,798] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:07,798] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:12,499] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:41:15,087] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:15,088] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:15,088] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:15,090] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,535] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:16,539] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,539] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,540] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,540] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,540] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,542] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,544] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,545] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,545] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,545] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,545] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,546] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,546] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,546] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,546] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,547] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,547] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,547] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,548] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,548] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,548] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,548] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,549] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,549] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,552] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,552] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,756] INFO [Controller id=0] New topics: [Set(bar)], deleted topics: [Set()], new partition replica assignment [Map(bar-1 -> Vector(0), bar-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:16,756] INFO [Controller id=0] New partition creation callback for bar-1,bar-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:17,240] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:17,240] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:21,550] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:41:22,802] INFO [Controller id=0] Starting topic deletion for topics bar (kafka.controller.KafkaController:66)
[2019-07-10 04:41:23,728] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:23,729] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:23,729] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:23,731] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,597] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:24,601] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,601] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,602] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,602] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,603] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,604] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,608] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,608] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,608] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,608] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,608] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,609] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,609] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,609] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,609] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,610] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,610] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,610] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,611] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,611] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,611] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,611] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,611] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,612] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,614] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:24,614] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:25,874] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:25,875] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:25,875] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:25,877] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,642] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:26,644] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,645] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,645] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,645] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,646] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,647] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,649] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,649] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,649] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,649] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,650] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,650] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,650] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,650] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,650] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,651] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,651] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,651] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,651] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,652] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,652] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,652] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,652] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,652] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,655] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:26,655] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:27,036] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:27,036] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:31,653] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:41:33,919] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:33,919] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:33,919] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:33,921] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,683] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:36,686] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,686] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,687] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,687] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,688] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,689] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,692] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,693] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,693] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,693] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,693] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,693] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,694] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,694] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,694] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,695] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,695] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,695] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,696] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,696] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,696] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,696] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,696] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,697] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,698] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,699] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,992] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:36,993] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:41,697] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:41:43,835] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:43,836] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:43,836] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:43,838] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,739] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:44,743] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,743] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,744] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,745] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,745] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,747] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,749] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,749] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,750] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,751] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,751] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,751] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,751] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,752] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,752] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,752] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,753] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,753] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,753] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,755] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,755] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,965] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:44,965] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,573] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:46,573] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:46,573] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:46,575] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,802] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:41:46,804] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,805] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,805] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,806] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,806] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,807] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,809] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,809] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,810] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,811] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,811] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,811] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,812] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,812] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,812] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,812] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,812] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,813] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,814] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:46,814] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:47,098] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:41:47,098] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:41:51,813] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:42:04,226] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:04,228] INFO [ControllerEventThrea
...[truncated 24195 chars]...
ion for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,157] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,157] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,158] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,160] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,161] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,456] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:42,456] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:47,158] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:42:49,333] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:49,334] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:49,334] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:49,336] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,172] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:50,180] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,180] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,181] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,182] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,183] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,184] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,188] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,188] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,189] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,189] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,189] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,189] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,190] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,190] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,190] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,190] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,191] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,191] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,191] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,192] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,192] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,192] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,192] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,193] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,195] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,195] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,485] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:50,485] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:55,193] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:42:56,805] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:56,806] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:56,806] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:56,808] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,265] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:42:57,268] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,268] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,269] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,270] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,270] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,272] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,275] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,275] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,275] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,275] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,275] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,276] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,276] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,276] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,276] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,277] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,277] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,277] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,278] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,278] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,278] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,278] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,278] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,279] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,281] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,281] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,587] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:42:57,587] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:02,279] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:43:04,335] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:04,338] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:04,338] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:04,340] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,327] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:05,331] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,331] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,332] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,333] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,333] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,334] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,338] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,338] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,338] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,339] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,339] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,339] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,339] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,339] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,340] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,340] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,341] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,341] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,341] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,342] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,342] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,342] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,342] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,343] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,344] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,345] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,639] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:05,640] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:10,343] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:43:22,681] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:22,683] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:22,683] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:22,689] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,375] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:23,379] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,379] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,380] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,380] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,381] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,383] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,386] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,386] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,387] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,387] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,387] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,387] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,388] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,388] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,388] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,389] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,389] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,390] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,390] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,390] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,391] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,391] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,391] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,391] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,393] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,394] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,704] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:23,705] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:28,392] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:43:29,888] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:29,888] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:29,888] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:29,891] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,431] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:30,434] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,434] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,435] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,435] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,436] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,436] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,440] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,440] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,441] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,441] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,441] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,442] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,442] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,442] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,442] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,442] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,443] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,443] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,444] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,444] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,444] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,444] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,444] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,445] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,447] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,447] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,737] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:30,737] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:35,446] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:43:36,921] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:36,922] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:36,922] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:36,924] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,519] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:39,522] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,523] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,523] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,524] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,524] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,526] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,530] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,530] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,530] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,531] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,531] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,531] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,531] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,532] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,532] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,532] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,533] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,533] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,534] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,534] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,534] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,534] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,534] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,535] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,537] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,537] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,831] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:39,831] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,222] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:41,223] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:41,223] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:41,225] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,556] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:43:41,560] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,561] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,562] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,562] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,563] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,565] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,568] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,568] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,568] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,568] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,568] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,569] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,569] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,569] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,569] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,570] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,570] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,570] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,571] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,571] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,571] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,571] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,571] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,572] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,573] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,573] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,799] INFO [Controller id=0] New topics: [Set(foo1)], deleted topics: [Set()], new partition replica assignment [Map(foo1-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,800] INFO [Controller id=0] New partition creation callback for foo1-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,997] INFO [Controller id=0] New topics: [Set(foo2)], deleted topics: [Set()], new partition replica assignment [Map(foo2-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:41,998] INFO [Controller id=0] New partition creation callback for foo2-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:42,199] INFO [Controller id=0] New topics: [Set(foo3)], deleted topics: [Set()], new partition replica assignment [Map(foo3-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:42,199] INFO [Controller id=0] New partition creation callback for foo3-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:42,365] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:43:42,366] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:43:46,572] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:44:13,549] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:13,550] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:13,550] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:13,552] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,658] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:14,661] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,661] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,662] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,662] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,663] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,664] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,668] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,668] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,668] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,668] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,668] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,669] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,669] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,669] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,670] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,670] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,671] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,671] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,672] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,672] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,672] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,672] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,673] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,674] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,678] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,678] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,881] INFO [Controller id=0] New topics: [Set(topic1)], deleted topics: [Set()], new partition replica assignment [Map(topic1-1 -> Vector(0), topic1-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:14,881] INFO [Controller id=0] New partition creation callback for topic1-1,topic1-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:15,287] INFO [Controller id=0] New topics: [Set(topic2)], deleted topics: [Set()], new partition replica assignment [Map(topic2-1 -> Vector(0), topic2-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:15,288] INFO [Controller id=0] New partition creation callback for topic2-1,topic2-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:16,394] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:16,394] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:19,675] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:44:26,912] INFO [Controller id=0] Starting topic deletion for topics topic1,topic2 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:28,238] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:28,241] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:28,241] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:28,244] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,732] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:30,735] INFO [Controller id=0] 0 successfully elected as the controller. Epoch incremented to 1 and epoch zk version is now 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,735] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,736] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,736] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,736] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,737] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,740] INFO [Controller id=0] Partitions being reassigned: Map() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,740] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,740] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,741] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,741] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,741] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,742] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,742] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,742] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,743] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,743] INFO [Controller id=0] Removing partitions Set() from the list of reassigned partitions in zookeeper (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,743] INFO [Controller id=0] No more partitions need to be reassigned. Deleting zk path /admin/reassign_partitions (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,744] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,744] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,744] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,745] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,745] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggerd by ZkTriggered (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,746] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,749] INFO [Controller id=0] New topics: [Set(foo)], deleted topics: [Set()], new partition replica assignment [Map(foo-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,749] INFO [Controller id=0] New partition creation callback for foo-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,953] INFO [Controller id=0] New topics: [Set(topic1)], deleted topics: [Set()], new partition replica assignment [Map(topic1-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:30,953] INFO [Controller id=0] New partition creation callback for topic1-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:31,157] INFO [Controller id=0] New topics: [Set(topic2)], deleted topics: [Set()], new partition replica assignment [Map(topic2-0 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:31,158] INFO [Controller id=0] New partition creation callback for topic2-0 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:31,435] INFO [Controller id=0] New topics: [Set(__consumer_offsets)], deleted topics: [Set()], new partition replica assignment [Map(__consumer_offsets-4 -> Vector(0), __consumer_offsets-3 -> Vector(0), __consumer_offsets-2 -> Vector(0), __consumer_offsets-0 -> Vector(0), __consumer_offsets-1 -> Vector(0))] (kafka.controller.KafkaController:66)
[2019-07-10 04:44:31,436] INFO [Controller id=0] New partition creation callback for __consumer_offsets-4,__consumer_offsets-3,__consumer_offsets-2,__consumer_offsets-0,__consumer_offsets-1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:35,747] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
[2019-07-10 04:44:42,126] INFO [Controller id=0] Starting topic deletion for topics topic1 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:42,134] INFO [Controller id=0] Starting topic deletion for topics topic1,topic2 (kafka.controller.KafkaController:66)
[2019-07-10 04:44:43,429] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:43,430] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:43,430] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
[2019-07-10 04:44:43,431] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)