File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
spring-kafka/src/main/java/org/springframework/kafka/listener Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -573,24 +573,24 @@ private TransactionTemplate determineTransactionTemplate() {
573573 }
574574
575575 private boolean determineAutoCommit (Properties consumerProperties ) {
576- boolean autoCommit ;
576+ boolean isAutoCommit ;
577577 String autoCommitOverride = consumerProperties .getProperty (ConsumerConfig .ENABLE_AUTO_COMMIT_CONFIG );
578578 if (!KafkaMessageListenerContainer .this .consumerFactory .getConfigurationProperties ()
579579 .containsKey (ConsumerConfig .ENABLE_AUTO_COMMIT_CONFIG )
580580 && autoCommitOverride == null ) {
581581 consumerProperties .setProperty (ConsumerConfig .ENABLE_AUTO_COMMIT_CONFIG , "false" );
582- autoCommit = false ;
582+ isAutoCommit = false ;
583583 }
584584 else if (autoCommitOverride != null ) {
585- autoCommit = Boolean .parseBoolean (autoCommitOverride );
585+ isAutoCommit = Boolean .parseBoolean (autoCommitOverride );
586586 }
587587 else {
588- autoCommit = KafkaMessageListenerContainer .this .consumerFactory .isAutoCommit ();
588+ isAutoCommit = KafkaMessageListenerContainer .this .consumerFactory .isAutoCommit ();
589589 }
590- Assert .state (!this .isAnyManualAck || !autoCommit ,
590+ Assert .state (!this .isAnyManualAck || !isAutoCommit ,
591591 () -> "Consumer cannot be configured for auto commit for ackMode "
592592 + this .containerProperties .getAckMode ());
593- return autoCommit ;
593+ return isAutoCommit ;
594594 }
595595
596596 private Duration determineSyncCommitTimeout () {
You can’t perform that action at this time.
0 commit comments