Skip to content

GH-3193 Add ackCount and ackTime to KafkaConsumerProperties - #3251

Open
akenra wants to merge 1 commit into
spring-cloud:mainfrom
akenra:bugfix/gh-3193
Open

GH-3193 Add ackCount and ackTime to KafkaConsumerProperties#3251
akenra wants to merge 1 commit into
spring-cloud:mainfrom
akenra:bugfix/gh-3193

Conversation

@akenra

@akenra akenra commented Aug 20, 2026

Copy link
Copy Markdown
Contributor

Add binding-level ackCount and ackTime options to KafkaConsumerProperties.

Currently, users who need to set ackCount/ackTime per binding have to do so globally
via spring.kafka.listener or through a ListenerContainerCustomizer. This change exposes
both properties at the binding level, e.g.:

spring:
  cloud:
    stream:
      kafka:
        bindings:
          my-binding:
            consumer:
              ackCount: 10
              ackTime: 5s

When unset, the binding-level properties stay null so the global spring.kafka.listener
values and any ListenerContainerCustomizer behavior are preserved.

Resolves: #3193

Signed-off-by: akenra <37288280+akenra@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add ackCount and ackTime to KafkaConsumerProperties

1 participant