Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9179

Flaky test kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.5.0
    • Fix Version/s: None
    • Component/s: admin, unit tests
    • Labels:

      Description

      Error Message
      java.lang.AssertionError: --under-replicated-partitions shouldn't return anything
      Stacktrace
      java.lang.AssertionError: --under-replicated-partitions shouldn't return anything
      	at org.junit.Assert.fail(Assert.java:89)
      	at org.junit.Assert.assertTrue(Assert.java:42)
      	at kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress(TopicCommandWithAdminClientTest.scala:694)
      	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.lang.reflect.Method.invoke(Method.java:498)
      	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
      	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
      	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
      	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
      	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
      	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
      	at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
      	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
      	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
      	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:365)
      	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
      	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
      	at org.junit.runners.ParentRunner$4.run(ParentRunner.java:330)
      	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:78)
      	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:328)
      	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:65)
      	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
      	at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
      	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
      	at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
      	at org.junit.runners.ParentRunner.run(ParentRunner.java:412)
      	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
      	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
      	at org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
      	at org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
      	at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
      	at sun.reflect.GeneratedMethodAccessor25.invoke(Unknown Source)
      	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.lang.reflect.Method.invoke(Method.java:498)
      	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
      	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
      	at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
      	at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
      	at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
      	at org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:118)
      	at sun.reflect.GeneratedMethodAccessor24.invoke(Unknown Source)
      	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.lang.reflect.Method.invoke(Method.java:498)
      	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
      	at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
      	at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182)
      	at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164)
      	at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:412)
      	at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
      	at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
      	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
      	at java.lang.Thread.run(Thread.java:748)
      
      Standard Output
      [2019-11-13 09:35:06,153] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,157] 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-11-13 09:35:06,157] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,158] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,159] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,160] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,161] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,164] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,165] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,165] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,165] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,166] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,166] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,166] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,166] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,166] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,167] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,202] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,202] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,203] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,203] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,244] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,244] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,245] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,246] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,292] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,292] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,294] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,294] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,339] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,340] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,341] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,342] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,388] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:06,389] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,390] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,391] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,408] INFO [Controller id=0] New topics: [Set(testAlterPartitionCount-W6YLQv6tF0)], deleted topics: [Set()], new partition replica assignment [Map(testAlterPartitionCount-W6YLQv6tF0-1 -> ReplicaAssignment(replicas=1,0, addingReplicas=, removingReplicas=), testAlterPartitionCount-W6YLQv6tF0-0 -> ReplicaAssignment(replicas=0,5, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,408] INFO [Controller id=0] New partition creation callback for testAlterPartitionCount-W6YLQv6tF0-1,testAlterPartitionCount-W6YLQv6tF0-0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:06,416] ERROR [ReplicaFetcher replicaId=5, leaderId=0, fetcherId=0] Error for partition testAlterPartitionCount-W6YLQv6tF0-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-13 09:35:11,168] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,447] INFO [Controller id=0] New partitions to be added Map(testAlterPartitionCount-W6YLQv6tF0-2 -> Vector(4, 3)) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,447] INFO [Controller id=0] New partition creation callback for testAlterPartitionCount-W6YLQv6tF0-2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,457] INFO [Controller id=0] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,459] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,459] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,461] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,462] INFO [Controller id=0] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,462] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,564] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,566] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,667] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:16,668] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,608] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,608] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,608] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,608] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,611] INFO [Controller id=0] Newly added brokers: , deleted brokers: 5, bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,612] INFO [Controller id=0] Broker failure callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,612] INFO [Controller id=0] Removed 5 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,615] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,624] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,625] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,625] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,625] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,628] INFO [Controller id=0] Newly added brokers: , deleted brokers: 1, bounced brokers: , all live brokers: 0,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,628] INFO [Controller id=0] Broker failure callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,628] INFO [Controller id=0] Removed 1 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,631] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,711] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,711] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,711] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,712] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,715] INFO [Controller id=0] Newly added brokers: , deleted brokers: 3, bounced brokers: , all live brokers: 0,2,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,715] INFO [Controller id=0] Broker failure callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,715] INFO [Controller id=0] Removed 3 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,719] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,846] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,846] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,846] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,847] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,850] INFO [Controller id=0] Newly added brokers: , deleted brokers: 2, bounced brokers: , all live brokers: 0,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,851] INFO [Controller id=0] Broker failure callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,851] INFO [Controller id=0] Removed 2 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,853] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,958] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,958] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,958] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,959] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,961] INFO [Controller id=0] Newly added brokers: , deleted brokers: 4, bounced brokers: , all live brokers: 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,962] INFO [Controller id=0] Broker failure callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,962] INFO [Controller id=0] Removed 4 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,966] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:17,975] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,975] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,975] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:17,976] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,445] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,448] 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-11-13 09:35:19,448] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,450] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,450] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,451] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,452] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,454] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,455] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,455] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,455] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,456] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,488] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,488] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,489] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,489] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,532] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,532] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,533] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,534] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,579] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,580] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,581] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,581] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,619] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,620] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,622] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,622] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,666] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:19,667] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,668] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,669] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,689] INFO [Controller id=0] New topics: [Set(testCreateWithDefaultReplication-Rx1zDQmPS7)], deleted topics: [Set()], new partition replica assignment [Map(testCreateWithDefaultReplication-Rx1zDQmPS7-1 -> ReplicaAssignment(replicas=4, addingReplicas=, removingReplicas=), testCreateWithDefaultReplication-Rx1zDQmPS7-0 -> ReplicaAssignment(replicas=1, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:19,689] INFO [Controller id=0] New partition creation callback for testCreateWithDefaultReplication-Rx1zDQmPS7-1,testCreateWithDefaultReplication-Rx1zDQmPS7-0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:24,457] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,718] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,719] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,719] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,719] INFO [Controller id=0] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,719] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:29,720] INFO [Controller id=0] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,581] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,582] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,582] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,582] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,586] INFO [Controller id=0] Newly added brokers: , deleted brokers: 3, bounced brokers: , all live brokers: 0,1,2,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,587] INFO [Controller id=0] Broker failure callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,587] INFO [Controller id=0] Removed 3 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,589] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,668] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,668] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,668] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,668] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,671] INFO [Controller id=0] Newly added brokers: , deleted brokers: 5, bounced brokers: , all live brokers: 0,1,2,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,672] INFO [Controller id=0] Broker failure callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,672] INFO [Controller id=0] Removed 5 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,674] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,735] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,735] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,735] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:30,735] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,838] INFO [Controller id=0] Newly added brokers: , deleted brokers: 2, bounced brokers: , all live brokers: 0,1,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,839] INFO [Controller id=0] Broker failure callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,839] INFO [Controller id=0] Removed 2 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:30,841] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,040] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,041] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,041] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,041] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,047] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,108] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,108] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,108] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,108] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,144] INFO [Controller id=0] Newly added brokers: , deleted brokers: 1,4, bounced brokers: , all live brokers: 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,145] INFO [Controller id=0] Broker failure callback for 1,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,145] INFO [Controller id=0] Removed 1,4 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,150] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:31,151] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,151] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:31,151] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,650] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,654] 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-11-13 09:35:33,654] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,655] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,656] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,657] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,658] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,661] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,661] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,661] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,661] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,662] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,662] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,662] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,662] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,662] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,663] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,663] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,664] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,664] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,664] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,665] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,698] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,698] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,699] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,700] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,749] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,749] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,750] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,751] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,789] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,790] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,791] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,791] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,889] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,890] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,891] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,892] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,934] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:33,935] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,936] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,936] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,953] INFO [Controller id=0] New topics: [Set(testDescribeAtMinIsrPartitions-hUmPg3GONV)], deleted topics: [Set()], new partition replica assignment [Map(testDescribeAtMinIsrPartitions-hUmPg3GONV-0 -> ReplicaAssignment(replicas=0,2,5,1,4,3, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:33,953] INFO [Controller id=0] New partition creation callback for testDescribeAtMinIsrPartitions-hUmPg3GONV-0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:38,665] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:43,971] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,104] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:45,105] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:45,105] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:45,108] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,112] INFO [Controller id=3] 3 successfully elected as the controller. Epoch incremented to 2 and epoch zk version is now 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,112] INFO [Controller id=3] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,113] INFO [Controller id=3] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,114] INFO [Controller id=3] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,114] INFO [Controller id=3] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,115] INFO [Controller id=3] Initialized broker epochs cache: Map(5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,124] INFO [Controller id=3] Currently active brokers in the cluster: Set(5, 1, 2, 3, 4) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,124] INFO [Controller id=3] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,124] INFO [Controller id=3] Current list of topics in the cluster: Set(testDescribeAtMinIsrPartitions-hUmPg3GONV) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,124] INFO [Controller id=3] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,125] INFO [Controller id=3] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,125] INFO [Controller id=3] List of topics ineligible for deletion: testDescribeAtMinIsrPartitions-hUmPg3GONV (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,125] INFO [Controller id=3] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,125] INFO [Controller id=3] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,127] INFO [Controller id=3] Ready to serve as the new controller with epoch 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,128] INFO [Controller id=3] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,128] INFO [Controller id=3] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,128] INFO [Controller id=3] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,128] INFO [Controller id=3] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,128] INFO [Controller id=3] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:45,129] INFO [Controller id=3] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:46,641] INFO [Controller id=3] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,519] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:47,519] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:47,519] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:47,519] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,623] INFO [Controller id=3] Newly added brokers: , deleted brokers: 1, bounced brokers: , all live brokers: 2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,624] INFO [Controller id=3] Broker failure callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,624] INFO [Controller id=3] Removed 1 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,625] INFO [Controller id=3] Updated broker epochs cache: Map(5 -> 108, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,747] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:47,748] INFO [Controller id=3] Newly added brokers: 0, deleted brokers: , bounced brokers: , all live brokers: 0,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,750] INFO [Controller id=3] New broker startup callback for 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,752] INFO [Controller id=3] Updated broker epochs cache: Map(0 -> 140, 5 -> 108, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,810] INFO [Controller id=3] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,810] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:47,811] INFO [Controller id=3] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,812] INFO [Controller id=3] Updated broker epochs cache: Map(0 -> 140, 5 -> 108, 1 -> 157, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,832] INFO [Controller id=3] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,834] INFO [Controller id=3] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,836] INFO [Controller id=3] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,837] INFO [Controller id=3] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,839] INFO [Controller id=3] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,840] INFO [Controller id=3] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:47,942] INFO [Controller id=3] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,044] INFO [Controller id=3] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,755] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,755] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,755] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,756] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,758] INFO [Controller id=3] Newly added brokers: , deleted brokers: 0, bounced brokers: , all live brokers: 1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,759] INFO [Controller id=3] Broker failure callback for 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,759] INFO [Controller id=3] Removed 0 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,762] INFO [Controller id=3] Updated broker epochs cache: Map(5 -> 108, 1 -> 157, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,823] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,823] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,823] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,823] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,826] INFO [Controller id=3] Newly added brokers: , deleted brokers: 1, bounced brokers: , all live brokers: 2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,827] INFO [Controller id=3] Broker failure callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,827] INFO [Controller id=3] Removed 1 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,830] INFO [Controller id=3] Updated broker epochs cache: Map(5 -> 108, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,911] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,911] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,911] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,911] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,914] INFO [Controller id=3] Newly added brokers: , deleted brokers: 4, bounced brokers: , all live brokers: 2,3,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,915] INFO [Controller id=3] Broker failure callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,915] INFO [Controller id=3] Removed 4 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,918] INFO [Controller id=3] Updated broker epochs cache: Map(5 -> 108, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,959] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,959] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,959] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:48,959] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,961] INFO [Controller id=3] Newly added brokers: , deleted brokers: 5, bounced brokers: , all live brokers: 2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,962] INFO [Controller id=3] Broker failure callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,962] INFO [Controller id=3] Removed 5 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:48,964] INFO [Controller id=3] Updated broker epochs cache: Map(2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,172] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,172] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,172] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,172] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,174] INFO [Controller id=3] Newly added brokers: , deleted brokers: 2, bounced brokers: , all live brokers: 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,175] INFO [Controller id=3] Broker failure callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,175] INFO [Controller id=3] Removed 2 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,178] INFO [Controller id=3] Updated broker epochs cache: Map(3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:49,612] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,612] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,612] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:49,613] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,949] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:35:50,952] 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-11-13 09:35:50,952] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,953] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,953] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,953] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,957] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,960] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,961] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,964] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,965] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,965] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,965] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,965] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:35:50,965] INFO [Controlle
      ...[truncated 654599 chars]...
       change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,371] INFO [Controller id=4] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,372] INFO [Controller id=4] Initialized broker epochs cache: Map(4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,373] INFO [Controller id=4] Currently active brokers in the cluster: Set(4) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,373] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:53,373] INFO [Controller id=4] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,374] INFO [Controller id=4] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,375] INFO [Controller id=4] Ready to serve as the new controller with epoch 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,375] INFO [Controller id=4] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,376] INFO [Controller id=4] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,376] INFO [Controller id=4] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,376] INFO [Controller id=4] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,376] INFO [Controller id=4] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,376] INFO [Controller id=4] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:53,377] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:53,377] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:53,377] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,329] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,333] 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-11-13 09:42:55,333] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,334] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,335] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,335] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,336] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,338] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,338] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,338] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,338] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,339] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,339] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,339] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,339] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,340] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,340] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,341] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,341] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,341] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,341] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,341] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,378] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,379] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,380] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,381] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,423] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,423] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,424] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,424] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,472] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,473] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,474] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,474] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,566] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,566] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,567] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,568] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,610] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:55,610] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,611] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,612] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,632] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,632] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,633] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,633] INFO [Controller id=0] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,633] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:55,633] INFO [Controller id=0] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,467] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,467] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,467] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,467] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,471] INFO [Controller id=0] Newly added brokers: , deleted brokers: 3, bounced brokers: , all live brokers: 0,1,2,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,472] INFO [Controller id=0] Broker failure callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,472] INFO [Controller id=0] Removed 3 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,472] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,561] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,561] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,561] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,562] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,565] INFO [Controller id=0] Newly added brokers: , deleted brokers: 4, bounced brokers: , all live brokers: 0,1,2,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,565] INFO [Controller id=0] Broker failure callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,565] INFO [Controller id=0] Removed 4 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,566] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,575] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,575] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,575] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,575] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,578] INFO [Controller id=0] Newly added brokers: , deleted brokers: 1, bounced brokers: , all live brokers: 0,2,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,578] INFO [Controller id=0] Broker failure callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,578] INFO [Controller id=0] Removed 1 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,579] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,619] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,619] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,619] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,620] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,723] INFO [Controller id=0] Newly added brokers: , deleted brokers: 2, bounced brokers: , all live brokers: 0,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,724] INFO [Controller id=0] Broker failure callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,724] INFO [Controller id=0] Removed 2 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,724] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,806] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,806] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,806] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:56,806] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,809] INFO [Controller id=0] Newly added brokers: , deleted brokers: 5, bounced brokers: , all live brokers: 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,809] INFO [Controller id=0] Broker failure callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,809] INFO [Controller id=0] Removed 5 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:56,809] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,144] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,145] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,145] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,146] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,764] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,767] 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-11-13 09:42:57,767] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,768] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,769] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,769] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,770] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,774] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,774] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,775] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,775] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,775] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,775] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,775] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,776] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,776] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,778] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,839] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,839] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,840] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,841] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,889] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,889] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,891] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,892] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,944] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,945] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,946] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,947] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,991] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:57,992] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,994] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:57,995] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:58,049] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:42:58,050] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:58,052] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:58,052] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:58,069] INFO [Controller id=0] New topics: [Set(testDescribe-Pod97AOmRF)], deleted topics: [Set()], new partition replica assignment [Map(testDescribe-Pod97AOmRF-1 -> ReplicaAssignment(replicas=1,5, addingReplicas=, removingReplicas=), testDescribe-Pod97AOmRF-0 -> ReplicaAssignment(replicas=0,2, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
      [2019-11-13 09:42:58,069] INFO [Controller id=0] New partition creation callback for testDescribe-Pod97AOmRF-1,testDescribe-Pod97AOmRF-0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:02,779] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,096] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,097] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,098] INFO [Controller id=0] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,099] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,100] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,101] INFO [Controller id=0] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,981] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:08,981] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:08,981] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:08,985] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,989] INFO [Controller id=5] 5 successfully elected as the controller. Epoch incremented to 2 and epoch zk version is now 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,989] INFO [Controller id=5] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,990] INFO [Controller id=5] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,990] INFO [Controller id=5] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,991] INFO [Controller id=5] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:08,992] INFO [Controller id=5] Initialized broker epochs cache: Map(5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,001] INFO [Controller id=5] Currently active brokers in the cluster: Set(5, 1, 2, 3, 4) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,001] INFO [Controller id=5] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,002] INFO [Controller id=5] Current list of topics in the cluster: Set(testDescribe-Pod97AOmRF) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,002] INFO [Controller id=5] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,002] INFO [Controller id=5] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,002] INFO [Controller id=5] List of topics ineligible for deletion: testDescribe-Pod97AOmRF (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,003] INFO [Controller id=5] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,003] INFO [Controller id=5] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,004] INFO [Controller id=5] Ready to serve as the new controller with epoch 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,005] INFO [Controller id=5] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,005] INFO [Controller id=5] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,005] INFO [Controller id=5] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,005] INFO [Controller id=5] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,006] INFO [Controller id=5] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,006] INFO [Controller id=5] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,257] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,257] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,257] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,258] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,261] INFO [Controller id=5] Newly added brokers: , deleted brokers: 1, bounced brokers: , all live brokers: 2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,262] INFO [Controller id=5] Broker failure callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,263] INFO [Controller id=5] Updated broker epochs cache: Map(5 -> 108, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,274] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,274] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,274] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,276] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,279] INFO [Controller id=3] 3 successfully elected as the controller. Epoch incremented to 3 and epoch zk version is now 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,279] INFO [Controller id=3] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,279] INFO [Controller id=3] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,280] INFO [Controller id=3] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,280] INFO [Controller id=3] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,281] INFO [Controller id=3] Initialized broker epochs cache: Map(2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,285] INFO [Controller id=3] Currently active brokers in the cluster: Set(2, 3, 4) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,285] INFO [Controller id=3] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,285] INFO [Controller id=3] Current list of topics in the cluster: Set(testDescribe-Pod97AOmRF) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,285] INFO [Controller id=3] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,286] INFO [Controller id=3] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,286] INFO [Controller id=3] List of topics ineligible for deletion: testDescribe-Pod97AOmRF (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,286] INFO [Controller id=3] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,286] INFO [Controller id=3] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,290] INFO [Controller id=3] Ready to serve as the new controller with epoch 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,291] INFO [Controller id=3] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,291] INFO [Controller id=3] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,291] INFO [Controller id=3] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,291] INFO [Controller id=3] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,291] INFO [Controller id=3] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,292] INFO [Controller id=3] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,345] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,346] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,346] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,347] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,351] INFO [Controller id=2] 2 successfully elected as the controller. Epoch incremented to 4 and epoch zk version is now 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,351] INFO [Controller id=2] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,352] INFO [Controller id=2] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,352] INFO [Controller id=2] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,353] INFO [Controller id=2] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,354] INFO [Controller id=2] Initialized broker epochs cache: Map(2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,358] INFO [Controller id=2] Currently active brokers in the cluster: Set(2, 4) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,358] INFO [Controller id=2] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] Current list of topics in the cluster: Set(testDescribe-Pod97AOmRF) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] List of topics ineligible for deletion: testDescribe-Pod97AOmRF (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,359] INFO [Controller id=2] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,363] INFO [Controller id=2] Ready to serve as the new controller with epoch 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,364] INFO [Controller id=2] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,364] INFO [Controller id=2] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,364] INFO [Controller id=2] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,365] INFO [Controller id=2] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,365] INFO [Controller id=2] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,365] INFO [Controller id=2] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,393] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,393] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,393] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,394] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,396] INFO [Controller id=2] Newly added brokers: , deleted brokers: 4, bounced brokers: , all live brokers: 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,397] INFO [Controller id=2] Broker failure callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,398] INFO [Controller id=2] Updated broker epochs cache: Map(2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:09,709] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,709] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,709] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:09,710] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,216] INFO [ControllerEventThread controllerId=0] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,219] 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-11-13 09:43:11,219] INFO [Controller id=0] Registering handlers (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,221] INFO [Controller id=0] Deleting log dir event notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,221] INFO [Controller id=0] Deleting isr change notifications (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,222] INFO [Controller id=0] Initializing controller context (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,223] INFO [Controller id=0] Initialized broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,225] INFO [Controller id=0] Currently active brokers in the cluster: Set(0) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,225] INFO [Controller id=0] Currently shutting brokers in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,225] INFO [Controller id=0] Current list of topics in the cluster: Set() (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,225] INFO [Controller id=0] Fetching topic deletions in progress (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,226] INFO [Controller id=0] List of topics to be deleted:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,226] INFO [Controller id=0] List of topics ineligible for deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,226] INFO [Controller id=0] Initializing topic deletion manager (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,226] INFO [Controller id=0] Sending update metadata request (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,227] INFO [Controller id=0] Ready to serve as the new controller with epoch 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,228] INFO [Controller id=0] Partitions undergoing preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,228] INFO [Controller id=0] Partitions that completed preferred replica election:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,228] INFO [Controller id=0] Skipping preferred replica election for partitions due to topic deletion:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,228] INFO [Controller id=0] Resuming preferred replica election for partitions:  (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,228] INFO [Controller id=0] Starting replica leader election (PREFERRED) for partitions  triggered by ZkTriggered (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,229] INFO [Controller id=0] Starting the controller scheduler (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,268] INFO [ControllerEventThread controllerId=1] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,268] INFO [Controller id=0] Newly added brokers: 1, deleted brokers: , bounced brokers: , all live brokers: 0,1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,269] INFO [Controller id=0] New broker startup callback for 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,270] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,322] INFO [ControllerEventThread controllerId=2] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,322] INFO [Controller id=0] Newly added brokers: 2, deleted brokers: , bounced brokers: , all live brokers: 0,1,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,324] INFO [Controller id=0] New broker startup callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,325] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,372] INFO [ControllerEventThread controllerId=3] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,373] INFO [Controller id=0] Newly added brokers: 3, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,374] INFO [Controller id=0] New broker startup callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,375] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,420] INFO [ControllerEventThread controllerId=4] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,420] INFO [Controller id=0] Newly added brokers: 4, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,421] INFO [Controller id=0] New broker startup callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,422] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,468] INFO [ControllerEventThread controllerId=5] Starting (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:11,468] INFO [Controller id=0] Newly added brokers: 5, deleted brokers: , bounced brokers: , all live brokers: 0,1,2,3,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,469] INFO [Controller id=0] New broker startup callback for 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,470] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 3 -> 76, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,488] INFO [Controller id=0] New topics: [Set(testAlterAssignment-IMAOw4n3SA)], deleted topics: [Set()], new partition replica assignment [Map(testAlterAssignment-IMAOw4n3SA-1 -> ReplicaAssignment(replicas=0,1, addingReplicas=, removingReplicas=), testAlterAssignment-IMAOw4n3SA-0 -> ReplicaAssignment(replicas=5,0, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,488] INFO [Controller id=0] New partition creation callback for testAlterAssignment-IMAOw4n3SA-1,testAlterAssignment-IMAOw4n3SA-0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:11,496] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition testAlterAssignment-IMAOw4n3SA-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-13 09:43:16,229] INFO [Controller id=0] Processing automatic preferred replica leader election (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,515] INFO [Controller id=0] New partitions to be added Map(testAlterAssignment-IMAOw4n3SA-2 -> Vector(4, 2)) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,515] INFO [Controller id=0] New partition creation callback for testAlterAssignment-IMAOw4n3SA-2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,526] INFO [Controller id=0] Shutting down broker 1 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,527] INFO [Controller id=0] Shutting down broker 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,527] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,529] INFO [Controller id=0] Shutting down broker 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,530] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,531] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,631] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,634] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,634] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,736] INFO [Controller id=0] Shutting down broker 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,738] INFO [Controller id=0] Shutting down broker 5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:21,739] INFO [Controller id=0] Shutting down broker 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,375] INFO [ControllerEventThread controllerId=3] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,375] INFO [ControllerEventThread controllerId=3] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,375] INFO [ControllerEventThread controllerId=3] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,375] INFO [Controller id=3] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,379] INFO [Controller id=0] Newly added brokers: , deleted brokers: 3, bounced brokers: , all live brokers: 0,1,2,4,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,379] INFO [Controller id=0] Broker failure callback for 3 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,379] INFO [Controller id=0] Removed 3 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,382] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60, 4 -> 92) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,639] INFO [ControllerEventThread controllerId=4] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,640] INFO [ControllerEventThread controllerId=4] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,640] INFO [ControllerEventThread controllerId=4] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,640] INFO [Controller id=4] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,643] INFO [Controller id=0] Newly added brokers: , deleted brokers: 4, bounced brokers: , all live brokers: 0,1,2,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,644] INFO [Controller id=0] Broker failure callback for 4 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,644] INFO [Controller id=0] Removed 4 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,647] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 5 -> 108, 1 -> 44, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=1] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=5] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=1] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=5] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=5] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,687] INFO [ControllerEventThread controllerId=1] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,688] INFO [Controller id=1] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,687] INFO [Controller id=5] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,690] INFO [Controller id=0] Newly added brokers: , deleted brokers: 1,5, bounced brokers: , all live brokers: 0,2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,691] INFO [Controller id=0] Broker failure callback for 1,5 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,691] INFO [Controller id=0] Removed 1,5 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,695] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25, 2 -> 60) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,942] INFO [ControllerEventThread controllerId=2] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,943] INFO [ControllerEventThread controllerId=2] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,943] INFO [ControllerEventThread controllerId=2] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:22,943] INFO [Controller id=2] Resigned (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,945] INFO [Controller id=0] Newly added brokers: , deleted brokers: 2, bounced brokers: , all live brokers: 0 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,946] INFO [Controller id=0] Broker failure callback for 2 (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,946] INFO [Controller id=0] Removed 2 from list of shutting down brokers. (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:22,950] INFO [Controller id=0] Updated broker epochs cache: Map(0 -> 25) (kafka.controller.KafkaController:66)
      [2019-11-13 09:43:23,033] INFO [ControllerEventThread controllerId=0] Shutting down (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:23,033] INFO [ControllerEventThread controllerId=0] Stopped (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:23,033] INFO [ControllerEventThread controllerId=0] Shutdown completed (kafka.controller.ControllerEventManager$ControllerEventThread:66)
      [2019-11-13 09:43:23,034] INFO [Controller id=0] Resigned (kafka.controller.KafkaController:66)
      Standard Error
      Option "[replica-assignment]" can't be used with option "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Missing required argument "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[if-exists]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[if-not-exists]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[replica-assignment]" can't be used with option "[replication-factor]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[delete-config]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Missing required argument "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.     
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                hachikuji Jason Gustafson
                Reporter:
                vvcephei John Roesler
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: