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

Flaky test kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

    XMLWordPrintableJSON

    Details

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

      Description

      Stacktrace:

      java.lang.NullPointerException
      	at kafka.admin.TopicCommandWithAdminClientTest.$anonfun$testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress$3(TopicCommandWithAdminClientTest.scala:673)
      	at kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress(TopicCommandWithAdminClientTest.scala:671)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
      	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:306)
      	at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
      	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
      	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:331)
      	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
      	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
      	at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
      	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
      	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:306)
      	at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
      	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 java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
      	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 java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
      	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.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      	at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
      	at java.base/java.lang.Thread.run(Thread.java:834)
      

      Standard output:

      Created topic testCreateWithDefaultReplication-TzaNGcD6mL.
      [2020-03-10 10:11:40,529] ERROR [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error for partition testDescribeAtMinIsrPartitions-LdzgScMUuy-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:11:40,533] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition testDescribeAtMinIsrPartitions-LdzgScMUuy-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      Created topic testCreateIfItAlreadyExists-tea1UkanNu.
      [2020-03-10 10:12:04,086] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition kafka.testTopic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:04,092] ERROR [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,229] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-17 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,229] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-5 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,244] ERROR [ReplicaFetcher replicaId=3, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-17 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,245] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-11 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,247] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-14 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,246] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,254] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-13 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,246] ERROR [ReplicaFetcher replicaId=5, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-3 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,254] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-15 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,256] ERROR [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-16 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      Created topic testCreateAlterTopicWithRackAware-wDCgC3q4uS.
      [2020-03-10 10:12:23,259] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-11 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,268] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-5 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,253] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-16 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,253] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-7 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,252] ERROR [ReplicaFetcher replicaId=4, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-9 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,252] ERROR [ReplicaFetcher replicaId=5, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-10 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,252] ERROR [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,252] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-9 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,272] ERROR [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-7 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,271] ERROR [ReplicaFetcher replicaId=5, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-4 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,269] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-4 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,259] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-14 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,275] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,262] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-8 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,276] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,256] ERROR [ReplicaFetcher replicaId=5, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-13 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,255] ERROR [ReplicaFetcher replicaId=5, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-15 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,272] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-3 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,430] ERROR [ReplicaFetcher replicaId=3, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-29 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,431] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-19 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,431] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-31 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,442] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-32 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,442] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-20 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,448] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-29 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,449] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-33 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,450] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-21 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,450] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-32 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,451] ERROR [ReplicaFetcher replicaId=5, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-25 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,448] ERROR [ReplicaFetcher replicaId=5, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-33 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,451] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-20 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,451] ERROR [ReplicaFetcher replicaId=5, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-22 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,452] ERROR [ReplicaFetcher replicaId=5, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-21 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,452] ERROR [ReplicaFetcher replicaId=5, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-34 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,453] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-23 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,454] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-35 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,453] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-27 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,456] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-23 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,457] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-35 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,457] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-22 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,459] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-34 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:23,460] ERROR [ReplicaFetcher replicaId=4, leaderId=0, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-wDCgC3q4uS-27 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      Created topic testTopicDeletion-KFosVGnPLw.
      Created topic testCreateWithDefaults-1HjRGXxa1i.
      Created topic testDescribeReportOverriddenConfigs-MQmTvVRNrT.
      [2020-03-10 10:12:36,102] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition testDescribeReportOverriddenConfigs-MQmTvVRNrT-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:43,622] ERROR [ReplicaFetcher replicaId=5, leaderId=2, fetcherId=0] Error for partition kafka.testTopic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:12:47,813] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testAlterAssignmentWithMoreAssignmentThanPartitions-RyfROWE4t9-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      Created topic testCreateWithDefaultPartitions-lmUm4iOhYU.
      Created topic testListTopics-js9Zyn4bGs.
      WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
      Created topic __consumer_offsets.
      Created topic testConfigPreservationAcrossPartitionAlteration-bFfxFd2mQV.
      Created topic testCreateWithConfigs-RFZlAnZGsC.
      [2020-03-10 10:13:21,139] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-pJH315jRjQ-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:13:21,142] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-pJH315jRjQ-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:13:21,143] ERROR [ReplicaFetcher replicaId=5, leaderId=4, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-pJH315jRjQ-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2020-03-10 10:13:21,143] ERROR [ReplicaFetcher replicaId=3, leaderId=4, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-pJH315jRjQ-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      Created topic testDescribeAndListTopicsWithoutInternalTopics-o9HwVMcCsB.
      WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
      Created topic __consumer_offsets.
      Created topic testCreateWithReplicaAssignment-jnAcY2d2ck.
      Created topic testAlterWithInvalidPartitionCount-ojsK73bBtC.
      Created topic testCreate-RWpMOPTUM3.
      [2020-03-10 10:14:34,288] ERROR [ReplicaFetcher replicaId=3, leaderId=2, fetcherId=0] Error for partition testAlterAssignment-JqE8hyg0UB-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      

      Standard error:

      Option "[replica-assignment]" can't be used with option "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Missing required argument "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[if-exists]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[if-not-exists]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[replica-assignment]" can't be used with option "[replication-factor]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option combination "[bootstrap-server],[config]" can't be used with option "[alter]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Option "[delete-config]" can't be used with option "[bootstrap-server]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      Missing required argument "[partitions]"
      Option                                   Description                            
      ------                                   -----------                            
      --alter                                  Alter the number of partitions,        
                                                 replica assignment, and/or           
                                                 configuration for the topic.         
      --at-min-isr-partitions                  if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 equal to the configured minimum. Not 
                                                 supported with the --zookeeper       
                                                 option.                              
      --bootstrap-server <String: server to    REQUIRED: The Kafka server to connect  
        connect to>                              to. In case of providing this, a     
                                                 direct Zookeeper connection won't be 
                                                 required.                            
      --command-config <String: command        Property file containing configs to be 
        config property file>                    passed to Admin Client. This is used 
                                                 only with --bootstrap-server option  
                                                 for describing and altering broker   
                                                 configs.                             
      --config <String: name=value>            A topic configuration override for the 
                                                 topic being created or altered.The   
                                                 following is a list of valid         
                                                 configurations:                      
                                               	cleanup.policy                        
                                               	compression.type                      
                                               	delete.retention.ms                   
                                               	file.delete.delay.ms                  
                                               	flush.messages                        
                                               	flush.ms                              
                                               	follower.replication.throttled.       
                                                 replicas                             
                                               	index.interval.bytes                  
                                               	leader.replication.throttled.replicas 
                                               	max.compaction.lag.ms                 
                                               	max.message.bytes                     
                                               	message.downconversion.enable         
                                               	message.format.version                
                                               	message.timestamp.difference.max.ms   
                                               	message.timestamp.type                
                                               	min.cleanable.dirty.ratio             
                                               	min.compaction.lag.ms                 
                                               	min.insync.replicas                   
                                               	preallocate                           
                                               	retention.bytes                       
                                               	retention.ms                          
                                               	segment.bytes                         
                                               	segment.index.bytes                   
                                               	segment.jitter.ms                     
                                               	segment.ms                            
                                               	unclean.leader.election.enable        
                                               See the Kafka documentation for full   
                                                 details on the topic configs.It is   
                                                 supported only in combination with --
                                                 create if --bootstrap-server option  
                                                 is used.                             
      --create                                 Create a new topic.                    
      --delete                                 Delete a topic                         
      --delete-config <String: name>           A topic configuration override to be   
                                                 removed for an existing topic (see   
                                                 the list of configurations under the 
                                                 --config option). Not supported with 
                                                 the --bootstrap-server option.       
      --describe                               List details for the given topics.     
      --disable-rack-aware                     Disable rack aware replica assignment  
      --exclude-internal                       exclude internal topics when running   
                                                 list or describe command. The        
                                                 internal topics will be listed by    
                                                 default                              
      --force                                  Suppress console prompts               
      --help                                   Print usage information.               
      --if-exists                              if set when altering or deleting or    
                                                 describing topics, the action will   
                                                 only execute if the topic exists.    
                                                 Not supported with the --bootstrap-  
                                                 server option.                       
      --if-not-exists                          if set when creating topics, the       
                                                 action will only execute if the      
                                                 topic does not already exist. Not    
                                                 supported with the --bootstrap-      
                                                 server option.                       
      --list                                   List all available topics.             
      --partitions <Integer: # of partitions>  The number of partitions for the topic 
                                                 being created or altered (WARNING:   
                                                 If partitions are increased for a    
                                                 topic that has a key, the partition  
                                                 logic or ordering of the messages    
                                                 will be affected). If not supplied   
                                                 for create, defaults to the cluster  
                                                 default.                             
      --replica-assignment <String:            A list of manual partition-to-broker   
        broker_id_for_part1_replica1 :           assignments for the topic being      
        broker_id_for_part1_replica2 ,           created or altered.                  
        broker_id_for_part2_replica1 :                                                
        broker_id_for_part2_replica2 , ...>                                           
      --replication-factor <Integer:           The replication factor for each        
        replication factor>                      partition in the topic being         
                                                 created. If not supplied, defaults   
                                                 to the cluster default.              
      --topic <String: topic>                  The topic to create, alter, describe   
                                                 or delete. It also accepts a regular 
                                                 expression, except for --create      
                                                 option. Put topic name in double     
                                                 quotes and use the '\' prefix to     
                                                 escape regular expression symbols; e.
                                                 g. "test\.topic".                    
      --topics-with-overrides                  if set when describing topics, only    
                                                 show topics that have overridden     
                                                 configs                              
      --unavailable-partitions                 if set when describing topics, only    
                                                 show partitions whose leader is not  
                                                 available                            
      --under-min-isr-partitions               if set when describing topics, only    
                                                 show partitions whose isr count is   
                                                 less than the configured minimum.    
                                                 Not supported with the --zookeeper   
                                                 option.                              
      --under-replicated-partitions            if set when describing topics, only    
                                                 show under replicated partitions     
      --version                                Display Kafka version.                 
      --zookeeper <String: hosts>              DEPRECATED, The connection string for  
                                                 the zookeeper connection in the form 
                                                 host:port. Multiple hosts can be     
                                                 given to allow fail-over.            
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                tombentley Tom Bentley
                Reporter:
                tombentley Tom Bentley
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: