春云流3.x-回放消息策略

Question

我正在寻找一些关于利用Spring Cloud Stream 3 . x/Kafka binder实现的Kafka主题的重放消息策略的指导-

> < li>

重播特定消息[例如通过时间戳窗口]。如何为消费者组中的所有或部分消费者重置补偿？

是否可以从主题的特定分区重播[如果我们知道我们有兴趣重放的消息的分区]？

一般来说，关于消息回放的最佳实践是什么。感谢您抽出时间。

Answer 1

添加一个重新平衡侦听器 bean，它将被连接到绑定器中......

@Bean
KafkaBindingRebalanceListener rebal() {
    return new KafkaBindingRebalanceListener() {

        @Override
        public void onPartitionsAssigned(String bindingName, Consumer<?, ?> consumer,
                Collection<TopicPartition> partitions, boolean initial) {

            consumer.seekToBeginning(partitions);
        }

    };
}

您可以使用任何消费者寻求操作；您也可以调用< code>consumer.offsetsForTimes(...)等。

对于第一次重新平衡,< code>initial标志为真，对于其他重新平衡为假。