Kafka Consumer получает назначенные разделы для определенной темы

Question

Я работаю с Kafka Consumer и подписываюсь только на одну тему.Я хочу вернуть только назначенные разделы из темы для каждого потребителя.Я запускаю четыре экземпляра получателя в одной группе и читаю тему с 8 разделами.

Я знаю, что могу использовать метод assignment (), но, похоже, он возвращает имя темы и раздел вформат - (т.е. тема1-0, тема1-1 и т. д.).Есть ли лучший способ получить раздел только без разбора значения, возвращенного методом assign ()?

Answer 1

public Set<TopicPartition> assignment ()

assignment() вернет набор TopicPartition

public int partition () , здесь

В TopicPartition у вас есть метод partition(), который дает раздел темы

Пример

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