Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8081

Flaky Test TopicCommandWithAdminClientTest#testDescribeUnderMinIsrPartitions

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: 2.3.0
    • Fix Version/s: 2.5.0
    • Component/s: admin, unit tests
    • Labels:

      Description

      https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/3450/tests

      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)

      STDOUT

      [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.

      STDERR

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                viktorsomogyi Viktor Somogyi-Vass
                Reporter:
                mjsax Matthias J. Sax
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: