我有一个主题列表(目前是10个)，其大小将来会增加。我知道我们可以产生多个线程(每个主题)来从每个主题中消费，但在我的情况下，如果主题数量增加，那么从主题中消费的线程数量也会增加，这是我不希望的，因为主题不是将过于频繁地获取数据，因此线程将处于理想状态。有没有办法让一个消费者消费所有主题？如果是，那么我们如何实现呢？此外，卡夫卡将如何维护偏移量？请提出答案。 最佳答案 我们可以使用以下API订阅多个主题:consumer.subscribe(Arrays.asList(topic1,topic2),ConsumerRebalance