[
https://issues.apache.org/jira/browse/KAFKA-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947824#comment-16947824
]
Bill Bejeck commented on KAFKA-8909:
------------------------------------
seen again in
[https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/25644/testReport/junit/kafka.admin/ReassignPartitionsClusterTest/shouldPerformMultipleReassignmentOperationsOverVariousTopics/]
{noformat}
Error Messagejava.lang.AssertionError: expected:<List(2, 3)> but was:<Vector(2,
1)>Stacktracejava.lang.AssertionError: expected:<List(2, 3)> but was:<Vector(2,
1)>
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.failNotEquals(Assert.java:835)
at org.junit.Assert.assertEquals(Assert.java:120)
at org.junit.Assert.assertEquals(Assert.java:146)
at
kafka.admin.ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics(ReassignPartitionsClusterTest.scala:601)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
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.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:365)
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:330)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:78)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:328)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:65)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
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:305)
at org.junit.runners.ParentRunner.run(ParentRunner.java:412)
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 sun.reflect.GeneratedMethodAccessor21.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
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 sun.reflect.GeneratedMethodAccessor20.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
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.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
at java.lang.Thread.run(Thread.java:748)
Standard Output[2019-10-09 05:14:17,429] ERROR [ReplicaFetcher replicaId=101,
leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Warning: You must run Verify periodically, until the reassignment completes, to
ensure the throttle is removed. You can also alter the throttle by rerunning
the Execute command passing a new value.
The inter-broker throttle limit was set to 10000000 B/s
Successfully started reassignment of partitions.
[2019-10-09 05:14:30,113] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:14:30,113] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:14:30,216] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:14:30,216] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":1,"replicas":[101,100],"log_dirs":["any","any"]},{"topic":"my-topic","partition":0,"replicas":[101,100],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Warning: You must run Verify periodically, until the reassignment completes, to
ensure the throttle is removed. You can also alter the throttle by rerunning
the Execute command passing a new value.
The inter-broker throttle limit was set to 1000000 B/s
Successfully started reassignment of partitions.
[2019-10-09 05:14:44,791] ERROR [ReplicaFetcher replicaId=2, leaderId=1,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:14:44,894] ERROR [ReplicaFetcher replicaId=2, leaderId=1,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:14:56,905] ERROR [Controller id=0] Ignoring request to reassign
partition customers-0 that doesn't exist. (kafka.controller.KafkaController:74)
[2019-10-09 05:14:57,810] ERROR [ReplicaFetcher replicaId=1, leaderId=2,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,463] ERROR [ReplicaFetcher replicaId=104, leaderId=103,
fetcherId=0] Error for partition topic1-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,465] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition topic1-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,465] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition topic1-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,568] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition topic1-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,568] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition topic1-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,975] ERROR [ReplicaFetcher replicaId=105, leaderId=104,
fetcherId=0] Error for partition topic2-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:06,975] ERROR [ReplicaFetcher replicaId=105, leaderId=104,
fetcherId=0] Error for partition topic2-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:07,078] ERROR [ReplicaFetcher replicaId=105, leaderId=104,
fetcherId=0] Error for partition topic2-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:07,078] ERROR [ReplicaFetcher replicaId=105, leaderId=104,
fetcherId=0] Error for partition topic2-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[103,104],"log_dirs":["any","any"]},{"topic":"topic2","partition":0,"replicas":[104,105],"log_dirs":["any","any"]},{"topic":"topic2","partition":1,"replicas":[104,105],"log_dirs":["any","any"]},{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"topic1","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"topic2","partition":2,"replicas":[103,104],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Warning: You must run Verify periodically, until the reassignment completes, to
ensure the throttle is removed. You can also alter the throttle by rerunning
the Execute command passing a new value.
The inter-broker throttle limit was set to 1000000 B/s
Successfully started reassignment of partitions.
[2019-10-09 05:15:13,420] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,420] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,420] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,523] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,523] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,524] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,626] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,626] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:13,626] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":2,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"my-topic","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Current partition replica assignment
{"version":1,"partitions":[{"topic":"A","partition":1,"replicas":[100],"log_dirs":["any"]},{"topic":"A","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
[2019-10-09 05:15:38,114] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,115] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,118] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,118] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,220] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,220] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,221] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,221] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,323] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,323] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,323] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:38,323] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:15:49,212] ERROR [ReplicaFetcher replicaId=102, leaderId=101,
fetcherId=0] Error for partition my-topic-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},{"topic":"my-topic","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Warning: You must run Verify periodically, until the reassignment completes, to
ensure the throttle is removed. You can also alter the throttle by rerunning
the Execute command passing a new value.
The inter-broker throttle limit was set to 1000000 B/s
Successfully started reassignment of partitions.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.
[2019-10-09 05:16:10,823] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,824] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,825] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,826] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,927] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,927] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,928] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:10,928] ERROR [ReplicaFetcher replicaId=2, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
The inter-broker throttle limit was set to 1000 B/s
[2019-10-09 05:16:16,877] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:16,981] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,249] ERROR [ReplicaFetcher replicaId=2, leaderId=1,
fetcherId=0] Error for partition orders-1 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,325] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,325] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-3 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,325] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,427] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-3 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,428] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:22,428] ERROR [ReplicaFetcher replicaId=1, leaderId=0,
fetcherId=0] Error for partition orders-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
[2019-10-09 05:16:33,376] ERROR [Controller id=0] Ignoring request to reassign
partition customers-0 that doesn't exist. (kafka.controller.KafkaController:74)
[2019-10-09 05:16:45,340] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
fetcherId=0] Error for partition my-topic-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Warning: You must run Verify periodically, until the reassignment completes, to
ensure the throttle is removed. You can also alter the throttle by rerunning
the Execute command passing a new value.
The inter-broker throttle limit was set to 1000000 B/s
Successfully started reassignment of partitions.
Status of partition reassignment:
Reassignment of partition my-topic-0 is still in progress
There is an existing assignment running.
Status of partition reassignment:
Reassignment of partition my-topic-0 completed successfully
Throttle was removed.
[2019-10-09 05:16:49,857] ERROR [ReplicaFetcher replicaId=100, leaderId=102,
fetcherId=0] Error for partition topic1-2 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Current partition replica assignment
{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},{"topic":"topic2","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"topic2","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},{"topic":"topic1","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},{"topic":"topic2","partition":2,"replicas":[102,100],"log_dirs":["any","any"]}]}
Save this to use as the --reassignment-json-file option during rollback
Successfully started reassignment of partitions.{noformat}
> Flaky Test
> ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics
> -----------------------------------------------------------------------------------------------------
>
> Key: KAFKA-8909
> URL: https://issues.apache.org/jira/browse/KAFKA-8909
> Project: Kafka
> Issue Type: Bug
> Components: core, security, unit tests
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Priority: Critical
> Labels: flaky-test
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/1673/testReport/junit/kafka.admin/ReassignPartitionsClusterTest/shouldPerformMultipleReassignmentOperationsOverVariousTopics/]
> {quote}java.lang.AssertionError: expected:<List(2, 3)> but was:<List(2, 1)>
> at org.junit.Assert.fail(Assert.java:89) at
> org.junit.Assert.failNotEquals(Assert.java:835) at
> org.junit.Assert.assertEquals(Assert.java:120) at
> org.junit.Assert.assertEquals(Assert.java:146) at
> kafka.admin.ReassignPartitionsClusterTest.shouldPerformMultipleReassignmentOperationsOverVariousTopics(ReassignPartitionsClusterTest.scala:601){quote}
> STDOUT
> {quote}[2019-09-15 18:22:58,255] ERROR [ReplicaFetcher replicaId=101,
> leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:22:58,359] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Warning: You must run Verify periodically, until the reassignment completes,
> to ensure the throttle is removed. You can also alter the throttle by
> rerunning the Execute command passing a new value. The inter-broker throttle
> limit was set to 10000000 B/s Successfully started reassignment of
> partitions. [2019-09-15 18:23:08,581] ERROR [ReplicaFetcher replicaId=101,
> leaderId=100, fetcherId=0] Error for partition my-topic-1 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:08,582] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:08,684] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:08,684] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. Current partition replica
> assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[101,100],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[101,100],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Warning: You must run Verify periodically, until the reassignment completes,
> to ensure the throttle is removed. You can also alter the throttle by
> rerunning the Execute command passing a new value. The inter-broker throttle
> limit was set to 1000000 B/s Successfully started reassignment of partitions.
> [2019-09-15 18:23:26,124] ERROR [ReplicaFetcher replicaId=2, leaderId=1,
> fetcherId=0] Error for partition orders-1 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:32,158] ERROR
> [Controller id=0] Ignoring request to reassign partition customers-0 that
> doesn't exist. (kafka.controller.KafkaController:74) [2019-09-15
> 18:23:43,429] ERROR [ReplicaFetcher replicaId=104, leaderId=103, fetcherId=0]
> Error for partition topic1-2 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,431] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> topic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,431] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,534] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> topic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,534] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,941] ERROR
> [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition
> topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:43,941] ERROR
> [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition
> topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:44,044] ERROR
> [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition
> topic2-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:44,045] ERROR
> [ReplicaFetcher replicaId=105, leaderId=104, fetcherId=0] Error for partition
> topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[103,104],"log_dirs":["any","any"]},\{"topic":"topic2","partition":0,"replicas":[104,105],"log_dirs":["any","any"]},\{"topic":"topic1","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"topic2","partition":2,"replicas":[103,104],"log_dirs":["any","any"]},\{"topic":"topic2","partition":1,"replicas":[104,105],"log_dirs":["any","any"]},\{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Warning: You must run Verify periodically, until the reassignment completes,
> to ensure the throttle is removed. You can also alter the throttle by
> rerunning the Execute command passing a new value. The inter-broker throttle
> limit was set to 1000000 B/s Successfully started reassignment of partitions.
> [2019-09-15 18:23:48,543] ERROR [ReplicaFetcher replicaId=101, leaderId=100,
> fetcherId=0] Error for partition my-topic-2 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,544] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,544] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,647] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,647] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,647] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,749] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,750] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:23:48,750] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> my-topic-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":2,"replicas":[100,101],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. Current partition replica
> assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"A","partition":0,"replicas":[100],"log_dirs":["any"]},\{"topic":"A","partition":1,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. Current partition replica
> assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. [2019-09-15 18:24:16,579]
> ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for
> partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,579] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,581] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,581] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,682] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,683] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,683] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:16,683] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:24,398] ERROR
> [ReplicaFetcher replicaId=102, leaderId=101, fetcherId=0] Error for partition
> my-topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"my-topic","partition":2,"replicas":[102,100],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. Current partition replica
> assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Warning: You must run Verify periodically, until the reassignment completes,
> to ensure the throttle is removed. You can also alter the throttle by
> rerunning the Execute command passing a new value. The inter-broker throttle
> limit was set to 1000000 B/s Successfully started reassignment of partitions.
> Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100],"log_dirs":["any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions. [2019-09-15 18:24:42,058]
> ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for
> partition orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,058] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,060] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,060] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,163] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,163] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,163] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:42,163] ERROR
> [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. The inter-broker throttle limit was set
> to 1000 B/s [2019-09-15 18:24:48,304] ERROR [ReplicaFetcher replicaId=101,
> leaderId=100, fetcherId=0] Error for partition my-topic-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,366] ERROR
> [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition
> orders-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,454] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-3 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,455] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,455] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,558] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,558] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,558] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-3 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,660] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,660] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:52,660] ERROR
> [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition
> orders-3 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:24:59,358] ERROR
> [Controller id=0] Ignoring request to reassign partition customers-0 that
> doesn't exist. (kafka.controller.KafkaController:74) [2019-09-15
> 18:25:14,001] ERROR [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0]
> Error for partition my-topic-0 at offset 0
> (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"my-topic","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Warning: You must run Verify periodically, until the reassignment completes,
> to ensure the throttle is removed. You can also alter the throttle by
> rerunning the Execute command passing a new value. The inter-broker throttle
> limit was set to 1000000 B/s Successfully started reassignment of partitions.
> Status of partition reassignment: Reassignment of partition my-topic-0 is
> still in progress There is an existing assignment running. Status of
> partition reassignment: Reassignment of partition my-topic-0 completed
> successfully Throttle was removed. [2019-09-15 18:25:18,997] ERROR
> [ReplicaFetcher replicaId=101, leaderId=100, fetcherId=0] Error for partition
> topic1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. [2019-09-15 18:25:18,998] ERROR
> [ReplicaFetcher replicaId=100, leaderId=102, fetcherId=0] Error for partition
> topic1-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
> does not host this topic-partition. Current partition replica assignment
> \{"version":1,"partitions":[{"topic":"topic1","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},\{"topic":"topic2","partition":0,"replicas":[100,101],"log_dirs":["any","any"]},\{"topic":"topic1","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"topic2","partition":2,"replicas":[102,100],"log_dirs":["any","any"]},\{"topic":"topic2","partition":1,"replicas":[101,102],"log_dirs":["any","any"]},\{"topic":"topic1","partition":0,"replicas":[100,101],"log_dirs":["any","any"]}]}
> Save this to use as the --reassignment-json-file option during rollback
> Successfully started reassignment of partitions.{quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
