如何扩展 Kafka 流



我有一个使用Apache Kafka Streams的应用程序。在Kafka Consumer的情况下,相同的consumer.group.id保证了不同实例(即不同的机器(中的不同应用程序被视为相同的消费者组。有没有和卡夫卡流中的consumer.group.id一样的东西?(即当它们有same configuration时,它们被视为相同的流(

Kstreams也有一个application.id形式的消费者名称。除了上述增加使用者以纵向扩展的方法之外,kstreams 还具有定义该特定使用者将运行的线程数的属性 - 可以赋予属性num.stream.threads更高的值(默认值为 1(以增加每个使用者中运行的线程数,从而纵向扩展流应用程序。

相关内容

  • 没有找到相关文章

最新更新