[ https://issues.apache.org/jira/browse/KAFKA-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952201#comment-16952201 ]
Matthias J. Sax commented on KAFKA-8909: ---------------------------------------- [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/25833/testReport/junit/kafka.admin/ReassignPartitionsClusterTest/shouldPerformMultipleReassignmentOperationsOverVariousTopics/] > 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)