apply review

spring-projects · Apr 23, 2024 · 974231d · 974231d
1 parent e6612cf
commit 974231d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...g-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java b/...g-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerEndpoint.java
@@ -327,15 +327,14 @@ public void setReplyTemplate(KafkaTemplate<?, ?> replyTemplate) {
 	@SuppressWarnings("unchecked")
 	public void setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V> recordFilterStrategy) {
 		this.recordFilterStrategy = (RecordFilterStrategy<K, V>) recordFilterStrategy;
-		setAckDiscarded(true);
 	}
 
 	protected boolean isAckDiscarded() {
 		return this.ackDiscarded;
 	}
 
 	/**
-	 * Set to true if the {@link #setRecordFilterStrategy(RecordFilterStrategy)} is in use.
+	 * Set to true if the {@link #setRecordFilterStrategy(RecordFilterStrategy)} should ack discarded messages.
 	 * @param ackDiscarded the ackDiscarded.
 	 */
 	public void setAckDiscarded(boolean ackDiscarded) {