如何扩展 Kafka 流？
How to scale up Kafka streams?
我有一个使用 Apache Kafka Streams 的应用程序。
对于 Kafka Consumer，same consumer.group.id 保证不同实例（即不同机器）中的不同应用程序被视为同一消费者组。
kafka 流中是否有与 consumer.group.id 相同的内容？ （即当他们有 same configuration 时，他们被认为是相同的流）
Kstreams 还有一个形式为application.id 的消费者名称。
除了上述增加消费者以扩大规模的方法外，kstreams 还有一个 属性 定义线程数，该线程数将被该特定消费者 运行 - 属性 num.stream.threads 可以被赋予更高的值（默认为 1）以增加每个消费者中的线程数 运行ning，从而扩展流应用程序。
我有一个使用 Apache Kafka Streams 的应用程序。
对于 Kafka Consumer，same consumer.group.id 保证不同实例（即不同机器）中的不同应用程序被视为同一消费者组。
kafka 流中是否有与 consumer.group.id 相同的内容？ （即当他们有 same configuration 时，他们被认为是相同的流）
Kstreams 还有一个形式为application.id 的消费者名称。
除了上述增加消费者以扩大规模的方法外，kstreams 还有一个 属性 定义线程数，该线程数将被该特定消费者 运行 - 属性 num.stream.threads 可以被赋予更高的值（默认为 1）以增加每个消费者中的线程数 运行ning，从而扩展流应用程序。