我们可以通过Kstream应用程序中的代码来控制消费者组中的消费者数量吗?
在我的应用程序中,我有8个实例,每个实例有20个线程,在我的使用者组中会创建多少使用者?
Kafka主题分区=480
会是8个实例*20个线程=160个消费者吗?
您可以控制一个应用程序中的线程数
您可以通过并行运行应用程序进程(JAR、Docker等(来控制实例的数量。
是的,您可以将它们相乘以获得每个application.id
的总消费者,尽管Kafka Streams可以同时消费多个主题,而不是所有主题都具有相同的分区计数