Kafka Consumer 获取特定主题的分配分区

Question

我正在与 Kafka Consumer 合作，并且只订阅一个主题。我只想返回每个消费者的主题分配的分区。我正在同一组中运行四个消费者实例，并读取具有 8 个分区的主题。

我知道我可以使用 assignment() 方法，但看起来它以 - 格式返回主题名称和分区（即 topic1-0、topic1-1 等）。有没有更好的方法只获取分区而不必解析从分配（）方法返回的值？

Answer 1

公共Set<TopicPartition>赋值()

assignment()将返回集合TopicPartition

公共 int 分区()。这里

在你有给出主题分区的TopicPartition方法中partition()

例子

Set<TopicPartition> partitions = consumer.assignment();
partitions.forEach(part->System.out.println(part.partition()));