apache-kafka - librdkafka partition.assignment.strategy 添加新策略

Question

今天使用 librdkafka， partition.assignment.strategy librdkafka有两个选项：范围和循环。我正在寻找是否有办法添加自定义分配策略。

最好的

Answer 1

截至今天（2021 年 6 月 18 日），librdkafka 尚不支持它。

您可以在此处找到功能请求： https ://github.com/edenhill/librdkafka/issues/2284

您只能从 3 种内置策略（范围、循环、合作粘性）中选择一种。记录在这里： https ://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md

Answer 2

还有另一种策略。在0.11.0版本中添加了一个新的策略，称为Sticky。它出现的主要原因之一是不仅要​​尝试尽可能均匀地分配主题分区，还要尽可能让分区留在现有的消费者那里。

当然，您也可以创建自己的策略。目前，AbstractPartitionAssignor它是一个抽象类，它对挖掘有关主题的数据进行一些常见的工作，以帮助实现您的逻辑。该博客解释了自定义分配策略。