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

Question

我正在与 Kafka 消费者合作，并且只订阅一个主题。我只想为每个消费者返回主题中分配的分区。我在同一个组中运行四个消费者实例，并读取一个包含 8 个分区的主题。我知道我可以使用 assignment() 方法，但看起来它以 - 格式返回主题名称和分区（即 topic1-0、topic1-1 等）。有没有更好的方法来获取分区而不必解析从 assignment() 方法返回的值？

Answer 1

公共Set<TopicPartition>分配（）

assignment()将返回一组TopicPartition

公共 int 分区（）。这里

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

例子

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