kafka获取主题的分区计数

  • Z时代
  • 2024-01-10
  • 分类：问答

如何从代码中获取任何kafka主题的分区数。我研究了许多链接，但似乎没有一个起作用。

提及一些：

http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count-

through-simpleclient-api

http://grokbase.com/t/kafka/users/151cv3htga/get-replication-and-partition-

count-of-a-topic

http://qnalist.com/questions/5809219/get-replication-and-partition-count-of-

a-topic

看起来像是类似的讨论。

SO上也有类似的链接，对此没有有效的解决方案。

回答：

在0.82 Producer API和0.9 Consumer api中，您可以使用类似

Properties configProperties = new Properties();
configProperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
configProperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.ByteArraySerializer");
configProperties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
org.apache.kafka.clients.producer.Producer producer = new KafkaProducer(configProperties);
producer.partitionsFor("test")

以上是 kafka获取主题的分区计数 的全部内容， 来源链接： utcz.com/qa/413292.html

回到顶部