GH-1704: Missing delegate method

Karol Dowbecki · garyrussell · commit f966ffff4dcb · 2021-09-23T13:40:57.000-04:00
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/CompositeRecordInterceptor.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/CompositeRecordInterceptor.java
@@ -87,4 +87,9 @@ public void clearThreadState(Consumer<?, ?> consumer) {
 		this.delegates.forEach(del -> del.clearThreadState(consumer));
 	}
 
+	@Override
+	public void afterRecord(ConsumerRecord<K, V> record, Consumer<K, V> consumer) {
+		this.delegates.forEach(del -> del.afterRecord(record, consumer));
+	}
+
 }

Original file line number	Diff line number	Diff line change
`@@ -87,4 +87,9 @@ public void clearThreadState(Consumer<?, ?> consumer) {`
`87`	`87`	`this.delegates.forEach(del -> del.clearThreadState(consumer));`
`88`	`88`	`}`
`89`	`89`
	`90`	`+ @Override`
	`91`	`+ public void afterRecord(ConsumerRecord<K, V> record, Consumer<K, V> consumer) {`
	`92`	`+ this.delegates.forEach(del -> del.afterRecord(record, consumer));`
	`93`	`+ }`
	`94`	`+`
`90`	`95`	`}`