在Kafka流中,当使用修改密钥的函数时,Kafka流会创建内部重新分区的主题。我想知道新创建的主题的分区数是多少?当新的主题分区数大于1时,消费者组中的其他消费者也会参与消费该内部主题?我正试图扩大我的一个消费者,但我试图首先了解它是如何工作的。
pxyaymoc1#
如果你不使用Repartitioned.numberOfPartitions()设置它,那么它和输入主题是一样的。参考值-Is there a way to repartition the input topic in Kafka streams?
Repartitioned.numberOfPartitions()
1条答案
按热度按时间pxyaymoc1#
如果你不使用
Repartitioned.numberOfPartitions()
设置它,那么它和输入主题是一样的。参考值-Is there a way to repartition the input topic in Kafka streams?