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

Question

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

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

Answer 1

公共Set<TopicPartition>分配（）assignment()将返回一组TopicPartition公共 int 分区（）。这里在TopicPartition你有partition()给出主题分区的方法中例子Set<TopicPartition>&nbsp;partitions&nbsp;=&nbsp;consumer.assignment(); partitions.forEach(part->System.out.println(part.partition()));