[
https://issues.apache.org/jira/browse/KAFKA-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062756#comment-17062756
]
ASF GitHub Bot commented on KAFKA-9691:
---------------------------------------
tombentley commented on pull request #8317: KAFKA-9691: Fix NPE by waiting for
reassignment request
URL: https://github.com/apache/kafka/pull/8317
It seems likely the NPE reported in KAFKA-9691 was due to the call to
`alterPartitionReassignments()` returning but the reassignment request not
being completed yet, so try to fix it by calling `get()` on the returned
`KafkaFuture`.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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)
