You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Mickael Maison (Jira)" <ji...@apache.org> on 2020/04/09 14:26:00 UTC
[jira] [Resolved] (KAFKA-9691) Flaky test
kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress
[ 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)