You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jason Gustafson (Jira)" <ji...@apache.org> on 2019/12/06 00:58:01 UTC
[jira] [Resolved] (KAFKA-9179) Flaky test
kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
[ https://issues.apache.org/jira/browse/KAFKA-9179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson resolved KAFKA-9179.
------------------------------------
Resolution: Fixed
> Flaky test kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-9179
> URL: https://issues.apache.org/jira/browse/KAFKA-9179
> Project: Kafka
> Issue Type: Bug
> Components: admin, unit tests
> Affects Versions: 2.5.0
> Reporter: John Roesler
> Assignee: Jason Gustafson
> Priority: Major
> Labels: flaky-test
>
> {noformat}
> 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)
> {noformat}
> {noformat}
> 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.
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)