我可以用spring cloud steam实现手动Kafka偏移管理吗每当我的使用者处理一条消息时，它都会将其偏移量提交到db中。不是Kafka每当我的使用者重新启动时，它都会从db读取最后一个处理的偏移量，寻找该偏移量并开始处理下一条消息。
fcwjkofz1#
springcloudstream允许您在使用者应用程序上手动确认消息。不确定为什么要将偏移量持久化为db（可能这是您的需要）。但我想知道使用手动确认模式是否有助于您的情况。您可以通过设置 spring.cloud.stream.kafka.bindings.<inboundChannelName>.consumer.autoCommitOffset 只有在消费者处理消息之后，才能对消息进行假确认和手动确认。你可以在这里找到一个例子
spring.cloud.stream.kafka.bindings.<inboundChannelName>.consumer.autoCommitOffset
1条答案
按热度按时间fcwjkofz1#
springcloudstream允许您在使用者应用程序上手动确认消息。不确定为什么要将偏移量持久化为db（可能这是您的需要）。但我想知道使用手动确认模式是否有助于您的情况。
您可以通过设置
spring.cloud.stream.kafka.bindings.<inboundChannelName>.consumer.autoCommitOffset只有在消费者处理消息之后，才能对消息进行假确认和手动确认。你可以在这里找到一个例子