我们可以通过Kstream应用中的代码来控制消费群体中的消费者数量吗？
在我的应用程序中，我有8个示例，每个示例有20个线程，我的消费者组中将创建多少个消费者？
Kafka主题分区=480
会是8个示例*20个线程=160个消费者吗？
svujldwt1#
您可以控制一个应用程序中的线程数
您可以通过并行运行应用进程(JAR、Docker等)来控制示例数量。
是的，您可以将它们相乘，得到每个application.id的总消费者，尽管Kafka Streams可以同时使用多个主题，但不是所有主题都具有相同的分区计数
application.id
1条答案
按热度按时间svujldwt1#
您可以控制一个应用程序中的线程数
您可以通过并行运行应用进程(JAR、Docker等)来控制示例数量。
是的，您可以将它们相乘，得到每个
application.id的总消费者，尽管Kafka Streams可以同时使用多个主题，但不是所有主题都具有相同的分区计数