我有一个使用Apache Kafka Streams的应用程序。在Kafka Consumer的情况下,相同的consumer.group.id
保证了不同实例(即不同的机器(中的不同应用程序被视为相同的消费者组。有没有和卡夫卡流中的consumer.group.id
一样的东西?(即当它们有same configuration
时,它们被视为相同的流(
Kstreams也有一个application.id
形式的消费者名称。除了上述增加使用者以纵向扩展的方法之外,kstreams 还具有定义该特定使用者将运行的线程数的属性 - 可以赋予属性num.stream.threads
更高的值(默认值为 1(以增加每个使用者中运行的线程数,从而纵向扩展流应用程序。