kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mickael Maison (Jira)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-9691) Flaky test kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
Date Thu, 09 Apr 2020 14:26:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Mickael Maison resolved KAFKA-9691.
-----------------------------------
    Fix Version/s: 2.6.0
       Resolution: Fixed

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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message