Каким образом потребительское автоматическое потребление кафки весенне-облачного потока нечеткое?

Когда я вручную признаю смещения в потребительском приложении, но я хочу, чтобы потребитель мог получить сообщение unacknowledge автоматически, но я не могу добиться успеха.
это мой конфиг YML: Каким образом потребительское автоматическое потребление кафки весенне-облачного потока нечеткое?

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

источник

2017-01-25 gemorn

Свойство resetOffsets, кажется, не используется в настоящее время: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/48#issuecomment-273111200.

По умолчанию потребителя auto.offset.reset будет установлен latest (то есть, если вы не явно установить группу для потребителя связывания с использованием spring.cloud.stream.bindings.input.group)

источник

2017-01-25 07:18:13

Я установил группу .if перезапустил приложение, все в порядке. , но я хочу получить сообщение 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 –

Кафка не имеет возможности подтвердить отдельные сообщения - как только смещение для группы/раздела было сохранено, все предыдущие сообщения считаются «подтвержденными» - то, что позволяет ручное подтверждение, - отложить процесс фиксации смещения в ситуациях, когда, например, сообщение обрабатывается асинхронно (а автоматическое подтверждение будет сохранять смещение до того, как сообщение фактически будет обрабатываться).

resetOffsets в настоящее время не поддерживается (это была функция, которую мы существенно сбросили после того, как мы перешли к новому потребительскому клиенту - см. https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/67), но, к сожалению, документация не отражает это.

источник

2017-01-25 14:04:34

Каким образом потребительское автоматическое потребление кафки весенне-облачного потока нечеткое?

ответ

Смежные вопросы