Skip to content

Commit 2cb40fe

Browse files
committed
Add ackMode attribute to @KafkaListener annotation
This commit introduces a new ackMode attribute to the @KafkaListener annotation, enabling per-listener acknowledgment mode configuration. This allows developers to override the container factory's default ackMode on a per-listener basis. The ackMode attribute accepts string values corresponding to ContainerProperties.AckMode enum values (e.g., "RECORD", "BATCH", "MANUAL", "MANUAL_IMMEDIATE"). Signed-off-by: Go BeomJun <alap_u@naver.com>
1 parent 61eb968 commit 2cb40fe

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,7 @@
344344
* <p>
345345
* Supports SpEL {@code #{...}} and property placeholders {@code ${...}}.
346346
* @return the ack mode (case-insensitive), or empty string to use factory default.
347-
* @since 4.1
347+
* @since 4.0.1
348348
* @see org.springframework.kafka.listener.ContainerProperties.AckMode
349349
*/
350350
String ackMode() default "";

0 commit comments

Comments
 (0)