File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -52,7 +52,7 @@ public class IgnoreEmptyBatchRecordFilterStrategy implements RecordFilterStrateg
5252 public boolean ignoreEmptyBatch() {
5353 return true;
5454 }
55- };
55+ }
5656
5757// NOTE: ignoreEmptyBatchRecordFilterStrategy is bean name of IgnoreEmptyBatchRecordFilterStrategy instance.
5858@KafkaListener(id = "filtered", topics = "topic", filter = "ignoreEmptyBatchRecordFilterStrategy")
@@ -77,7 +77,7 @@ public class NotIgnoreEmptyBatchRecordFilterStrategy implements RecordFilterStra
7777 public boolean ignoreEmptyBatch() {
7878 return false;
7979 }
80- };
80+ }
8181
8282// NOTE: notIgnoreEmptyBatchRecordFilterStrategy is bean name of NotIgnoreEmptyBatchRecordFilterStrategy instance.
8383@KafkaListener(id = "filtered", topics = "topic", filter = "notIgnoreEmptyBatchRecordFilterStrategy")
You can’t perform that action at this time.
0 commit comments