在Kafka流中,当使用修改密钥的函数时,Kafka streams会创建内部重新分区的主题。我想知道新创建的主题的分区数是多少?当新主题分区数大于1时,消费者组中的其他消费者也参与消费该内部主题?
我正试图扩大我的一个消费者,但我试图首先了解它是如何工作的。
如果不使用Repartitioned.numberOfPartitions()
设置它,那么它与输入主题相同。
参考-有没有办法在Kafka流中重新划分输入主题?