当Flink源运算符为并行时,单个分区的输入顺序是否确定?


0

我知道一个主题中的一条消息只能由一个组中的一个使用者使用,而在一个使用者组中,每个使用者负责一个或多个分区。

1 答案


0

对于您的第一个问题:“如果我有4个分区用于一个主题,并获取我使用的数据环境地址源(FlinkKafkaConsumer).setParallism(4),它真的会创建4个消费者实例吗?”

是的,flink将创建4个实例。

第二个问题是:“当4个消费者共享同一个分区时,如何保证消息的顺序?”

只有一个消费者会收到消息,其他消费者将无所事事。Flink保证按分区排序,你将按顺序接收消息。

更多详情请访问:https://www.verververica.com/blog/kafka-flink-a-practical-how-to


我来回答

写文章

提问题

面试题