[
https://issues.apache.org/jira/browse/KAFKA-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley updated KAFKA-9691:
-------------------------------
Labels: flaky-test (was: )
> 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
> Priority: Major
> Labels: flaky-test
>
> 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)
