我们可以通过Kafka中的代码来控制一个消费者群体中的消费者数量吗



我们可以通过Kstream应用程序中的代码来控制消费者组中的消费者数量吗?

在我的应用程序中,我有8个实例,每个实例有20个线程,在我的使用者组中会创建多少使用者?

Kafka主题分区=480

会是8个实例*20个线程=160个消费者吗?

您可以控制一个应用程序中的线程数

您可以通过并行运行应用程序进程(JAR、Docker等(来控制实例的数量。

是的,您可以将它们相乘以获得每个application.id的总消费者,尽管Kafka Streams可以同时消费多个主题,而不是所有主题都具有相同的分区计数

最新更新