apache-kafka Kafka重新划分河流

rbl8hiat  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(186)

在Kafka流中,当使用修改密钥的函数时,Kafka流会创建内部重新分区的主题。我想知道新创建的主题的分区数是多少?当新的主题分区数大于1时,消费者组中的其他消费者也会参与消费该内部主题?
我正试图扩大我的一个消费者,但我试图首先了解它是如何工作的。

pxyaymoc

pxyaymoc1#

如果你不使用Repartitioned.numberOfPartitions()设置它,那么它和输入主题是一样的。
参考值-Is there a way to repartition the input topic in Kafka streams?

相关问题