You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "John Roesler (Jira)" <ji...@apache.org> on 2019/11/13 14:16:00 UTC
[jira] [Created] (KAFKA-9179) Flaky test
kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
John Roesler created KAFKA-9179:
-----------------------------------
Summary: 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
{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)