我和一个Kafka消费者合作，只订阅一个主题。我只想为每个使用者返回主题中指定的分区。我正在同一组中运行四个consumer示例，并阅读一个包含8个分区的主题。我知道我可以使用assignment（）方法，但它似乎以-（即topic1-0、topic1-1等）的格式返回主题名称和分区。有没有更好的方法只获取分区而不必解析assignment（）方法返回的值？
kx7yvsdv1#
公开 Set<TopicPartition> 工作分配（） assignment() 将返回 TopicPartition public int partition（）。在这里在 TopicPartition 你有办法吗 partition() 这就是主题的划分例子
Set<TopicPartition>
assignment()
TopicPartition
partition()
Set<TopicPartition> partitions = consumer.assignment(); partitions.forEach(part->System.out.println(part.partition()));
1条答案
按热度按时间kx7yvsdv1#
公开
Set<TopicPartition>工作分配（）assignment()将返回TopicPartitionpublic int partition（）。在这里在
TopicPartition你有办法吗partition()这就是主题的划分例子