嗨，spring-kafka 如何处理消费者线程？

Question

有人可以告诉我 spring-Kafka 有像 spring-JMS 这样的功能，它可以根据负载动态地增加线程或减少线程吗？

使用Kafka，我们还需要担心线程管理这些东西吗？我知道 Kafka 消费者的最佳实践是拥有与您在该主题上拥有的分区数量相同的线程数量。

Answer 1

Spring for Apache Kafka 不会以任何方式动态调整消费者线程的数量。分区将分布在您配置的线程数上。

您可以在启动之前查询主题并适当配置容器。