如何解决Spring Cloud Stream 3.x-重播消息策略
我正在寻找有关使用Spring Cloud Stream 3.x / Kafka活页夹实现的Kafka主题中有关重播消息策略的指南-
-
重放特定消息[例如。按时间戳记窗口]从主题中选择。如何为消费者组中的所有或某些消费者重置偏移量?
-
是否可以从主题的特定分区重播[如果我们知道我们有兴趣重播的邮件分区]?
通常,围绕邮件重播的最佳做法是什么。谢谢您的时间。
解决方法
添加一个重新平衡的侦听器bean,它将被连接到活页夹中...
@Bean
KafkaBindingRebalanceListener rebal() {
return new KafkaBindingRebalanceListener() {
@Override
public void onPartitionsAssigned(String bindingName,Consumer<?,?> consumer,Collection<TopicPartition> partitions,boolean initial) {
consumer.seekToBeginning(partitions);
}
};
}
您可以使用任何消费者搜寻操作;您还可以致电consumer.offsetsForTimes(...)
等。
对于第一次重新平衡,initial
标志为true,对于其他重新平衡,则为false。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。