卡夫卡消费者得到分配的分区特定主题

Question

我与卡夫卡消费者的工作，并且只订阅一个话题。我想从每个消费者的话题只返回指定的分区。我运行在同一组消费者的四个实例，并读取一个话题8个分区。

我知道我可以使用赋值（）方法，但它看起来像在的格式返回主题名称和分区 - （即topic1-0，topic1-1等）。是否有获得分区只，而不必解析从分配（）方法的返回值的更好的办法？

Answer 1

公共Set<TopicPartition>分配（）

assignment()将返回集TopicPartition的

公众诠释分区（）。 here

在TopicPartition你有方法partition()，让话题的分

例

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