kafka获取主题的分区计数
如何从代码中获取任何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主题分区偏移位置始终从0或随机值开始，如何确保使用者记录是分区中的第一条记录？有没有办法找出答案？如果有的话，请让我知道。谢谢。
-
简单问题： 假设我有一个具有3个分区的主题：Topic：StateEvents P1、P2和P3。 让我们假设生产者生成20条消息： 1, 2, 3, ..........20 我的问题是: 当制作人生成这些消息时： 1）每个消息将只在且仅在1个分区？也就是说，1在P1,2在P2,3在P3，然后4在P1,5在P2,6在P3，以此类推？ 2）如果#1为真，当消费者订阅时，它将订阅所有分区，以便获得所
-
通过Kafka文档和各种其他资源，我了解到Kafka中的消息被组织成主题。此外，主题可以分解为多个分区，每个分区可以托管在不同的服务器上。这提供了冗余和可伸缩性。 我不确定这里的“破碎”这个词是什么意思。这是否意味着，如果添加到主题的消息是，例如“1 2 3 4 5 6 7”，那么在将其分解为分区后，我们将有一个分区仅包含整个主题的子部分。就像一个分区有“1 2 3”，而另一个分区有“4 5 6”
-
我开始学习Kafka用于企业解决方案。 在我阅读的过程中，我脑海中浮现出一些问题： > 当一个生产者正在生成一个消息--它会指定它想要将消息发送到的主题，是这样吗？它关心分区吗？ 当订阅服务器运行时-它是否指定其组id，以便它可以是同一主题的使用者集群的一部分，或者是该组使用者感兴趣的几个主题的一部分？ 每个消费者组在代理上有一个对应的分区还是每个消费者都有一个？ 分区是由代理创建的，因此不是消费
-
问题内容： 我正在使用Java 编写使用者。我想保持消息的实时性，因此，如果有太多消息在等待使用，例如1000条或更多，我应该放弃未使用的消息，并从最后一个偏移量开始使用。 对于此问题，我尝试比较主题的最后提交的偏移量和主题的结束偏移量（仅1个分区），如果这两个偏移量之间的差大于某个值，则将主题的最后提交的偏移量设置为下一个偏移量，这样我就可以放弃那些多余的消息。 现在我的问题是如何获得主题的最终
-
注：使用kafka_2.11-0.9.0.1 我创建了一个Kafka主题，名为：