SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix minor issue processing ackMode

Browse Source
This commit is contained in:
Soby Chacko
2021-02-19 12:58:59 -05:00
committed by Gary Russell
parent 394b8a6685
commit 1f52ec5020
1 changed files with 1 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -707,14 +707,10 @@ public class KafkaMessageChannelBinder extends
else {
messageListenerContainer.getContainerProperties()
.setAckOnError(isAutoCommitOnError(extendedConsumerProperties));
if (extendedConsumerProperties.getExtension().isAckEachRecord()) {
messageListenerContainer.getContainerProperties()
.setAckMode(ContainerProperties.AckMode.RECORD);
}
}
}
}
else {
if (ackMode != null) {
if ((extendedConsumerProperties.isBatchMode() && ackMode != ContainerProperties.AckMode.RECORD) ||
!extendedConsumerProperties.isBatchMode()) {
messageListenerContainer.getContainerProperties()
@@ -722,8 +718,6 @@ public class KafkaMessageChannelBinder extends
}
}
if (this.logger.isDebugEnabled()) {
this.logger.debug("Listened partitions: "
+ StringUtils.collectionToCommaDelimitedString(listenedPartitions));