卡夫卡流重新分区



在Kafka流中,当使用修改密钥的函数时,Kafka streams会创建内部重新分区的主题。我想知道新创建的主题的分区数是多少?当新主题分区数大于1时,消费者组中的其他消费者也参与消费该内部主题?

我正试图扩大我的一个消费者,但我试图首先了解它是如何工作的。

如果不使用Repartitioned.numberOfPartitions()设置它,那么它与输入主题相同。

参考-有没有办法在Kafka流中重新划分输入主题?

相关内容

  • 没有找到相关文章

最新更新