當我手動確認消費者應用程序中的偏移量,但我想消費者可以重新獲取unacknowledge消息自動,但我不能做到成功。
這是我的配置陽明: spring-cloud-stream kafka消費者如何自動重新獲取unacknowledge消息?
cloud:
stream:
kafka:
binder:
brokers: ****:****
za-nodes: ****
replication-factor: 1
bindings:
input:
consumer:
auto-commit-offset: false
auto-commit-on-error: false
reset-offsets: true
我設置了組。如果重新啓動應用程序,沒關係。 但我想檢索unacknowledge消息而不重新啓動應用程序 – gemorn
如果您想從「最新」開始,則不必設置組。此外,對於手動確認,您可以看到以下示例:http://docs.spring.io/spring-cloud-stream/docs/Brooklyn.BUILD-SNAPSHOT/reference/htmlsingle/index.html#_example_setting_literal_autocommitoffset_literal_false_and_relying_on_manual_acking –