[jira] [Commented] (KAFKA-8081) Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitions

["Viktor Somogyi-Vass (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-8081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955951#comment-16955951 ] 

Viktor Somogyi-Vass commented on KAFKA-8081:
--------------------------------------------

Since there were no reports of this test being flaky for a while now I'll close this JIRA. Please reopen it if the tests are still flaky.

> Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitions
> ----------------------------------------------------------------------------
>
>                 Key: KAFKA-8081
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8081
>             Project: Kafka
>          Issue Type: Bug
>          Components: admin, unit tests
>    Affects Versions: 2.3.0
>            Reporter: Matthias J. Sax
>            Priority: Critical
>              Labels: flaky-test
>             Fix For: 2.5.0
>
>
> [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3450/tests]
> {quote}java.lang.AssertionError
> at org.junit.Assert.fail(Assert.java:87)
> at org.junit.Assert.assertTrue(Assert.java:42)
> at org.junit.Assert.assertTrue(Assert.java:53)
> at kafka.admin.TopicCommandWithAdminClientTest.testDescribeUnderMinIsrPartitions(TopicCommandWithAdminClientTest.scala:560){quote}
> STDOUT
> {quote}[2019-03-09 00:13:23,129] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition testAlterPartitionCount-yrX0KHVdgf-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:13:23,130] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testAlterPartitionCount-yrX0KHVdgf-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:13:33,184] ERROR [ReplicaFetcher replicaId=4, leaderId=1, fetcherId=0] Error for partition testAlterPartitionCount-yrX0KHVdgf-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:13:36,319] WARN Unable to read additional data from client sessionid 0x10433c934dc0006, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:13:46,311] WARN Unable to read additional data from client sessionid 0x10433c98cb10003, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:13:46,356] WARN Unable to read additional data from client sessionid 0x10433c98cb10004, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:06,066] WARN Unable to read additional data from client sessionid 0x10433c9b17d0005, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:06,457] WARN Unable to read additional data from client sessionid 0x10433c9b17d0001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:11,206] ERROR [ReplicaFetcher replicaId=2, leaderId=3, 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.
> [2019-03-09 00:14:11,218] 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.
> [2019-03-09 00:14:22,096] WARN Unable to read additional data from client sessionid 0x10433c9f1210004, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:28,290] WARN Unable to read additional data from client sessionid 0x10433ca28de0005, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:28,733] WARN Unable to read additional data from client sessionid 0x10433ca28de0006, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:29,529] WARN Unable to read additional data from client sessionid 0x10433ca28de0000, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:31,841] WARN Unable to read additional data from client sessionid 0x10433ca39ed0002, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:14:40,221] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-16 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,222] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-10 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,227] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,228] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-8 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,228] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-17 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,234] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-5 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,240] ERROR [ReplicaFetcher replicaId=1, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-12 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,241] ERROR [ReplicaFetcher replicaId=1, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,255] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-17 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,256] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-11 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,264] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-6 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,264] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-5 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,269] ERROR [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-12 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,274] ERROR [ReplicaFetcher replicaId=4, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-6 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,275] ERROR [ReplicaFetcher replicaId=1, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,275] ERROR [ReplicaFetcher replicaId=5, leaderId=3, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,274] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-8 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,276] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-14 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,275] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:14:40,276] ERROR [ReplicaFetcher replicaId=3, leaderId=5, fetcherId=0] Error for partition testCreateAlterTopicWithRackAware-IQe98agDrW-14 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:15:10,438] WARN Unable to read additional data from client sessionid 0x10433caa5ac0006, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:15:14,594] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition testDescribeReportOverriddenConfigs-kGY7w0VgrA-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:15:25,535] WARN Unable to read additional data from client sessionid 0x10433cae8a40001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:15:32,033] WARN Unable to read additional data from client sessionid 0x10433cb28340002, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:15:39,261] ERROR [ReplicaFetcher replicaId=1, leaderId=5, 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.
> [2019-03-09 00:15:39,265] ERROR [ReplicaFetcher replicaId=0, 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.
> [2019-03-09 00:15:39,279] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition kafka.testTopic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:15:39,283] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition oooof.testTopic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:16:17,545] ERROR [ReplicaFetcher replicaId=5, leaderId=2, fetcherId=0] Error for partition testAlterAssignmentWithMoreAssignmentThanPartitions-LSf2ep4lv6-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:16:28,678] WARN Unable to read additional data from client sessionid 0x10433cbde9a0001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> 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.
> [2019-03-09 00:17:14,213] WARN Unable to read additional data from client sessionid 0x10433ccb77c0005, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:17:18,400] ERROR [ReplicaFetcher replicaId=5, leaderId=2, fetcherId=0] Error for partition testAlterAssignmentWithMorePartitionsThanAssignment-ySENVEYnGW-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:17:46,652] WARN Unable to read additional data from client sessionid 0x10433cd0f2b0001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:17:53,321] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testCreateWithConfigs-rLO2u8HtL7-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:18:12,597] ERROR [ReplicaFetcher replicaId=0, leaderId=5, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-VI7118JudA-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:18:12,602] ERROR [ReplicaFetcher replicaId=1, leaderId=5, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-VI7118JudA-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:18:12,601] ERROR [ReplicaFetcher replicaId=2, leaderId=5, fetcherId=0] Error for partition testDescribeUnderReplicatedPartitions-VI7118JudA-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:18:26,291] WARN Unable to read additional data from client sessionid 0x10433cda0020004, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:18:29,884] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition testDescribeUnderMinIsrPartitions-RfneLfKEJo-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> 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.
> [2019-03-09 00:19:10,129] WARN Unable to read additional data from client sessionid 0x10433ce2ee60001, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:19:30,151] WARN Unable to read additional data from client sessionid 0x10433ce98ef0007, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:19:43,227] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition testCreateWithReplicaAssignment-6sbOHGcl0i-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:19:43,228] ERROR [ReplicaFetcher replicaId=4, leaderId=5, fetcherId=0] Error for partition testCreateWithReplicaAssignment-6sbOHGcl0i-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:19:43,227] ERROR [ReplicaFetcher replicaId=2, leaderId=3, fetcherId=0] Error for partition testCreateWithReplicaAssignment-6sbOHGcl0i-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:19:54,265] WARN Unable to read additional data from client sessionid 0x10433cf020f0003, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:20:30,775] WARN Unable to read additional data from client sessionid 0x10433cf81560000, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:20:31,170] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:20:31,171] ERROR [ReplicaFetcher replicaId=0, leaderId=4, fetcherId=0] Error for partition under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:20:31,179] ERROR [ReplicaFetcher replicaId=1, leaderId=4, fetcherId=0] Error for partition under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:20:31,186] ERROR [ReplicaFetcher replicaId=4, leaderId=2, fetcherId=0] Error for partition not-under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:20:31,188] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition not-under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:20:31,195] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition not-under-min-isr-topic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:21:17,036] WARN Unable to read additional data from client sessionid 0x10433cfbd0b0003, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:21:17,574] WARN Unable to read additional data from client sessionid 0x10433cfbd0b0006, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn:376)
> [2019-03-09 00:21:38,878] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition testDescribe-Ty6ona1gLw-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:21:38,879] ERROR [ReplicaFetcher replicaId=1, leaderId=5, fetcherId=0] Error for partition testDescribe-Ty6ona1gLw-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:21:55,004] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition testAlterAssignment-0j7ldYE4Xb-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
> [2019-03-09 00:22:05,061] ERROR [ReplicaFetcher replicaId=2, leaderId=4, fetcherId=0] Error for partition testAlterAssignment-0j7ldYE4Xb-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
> org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.{quote}
> STDERR
> {quote}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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.
> --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.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
> --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.
> --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
> --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.{quote}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)