Skip to content

Commit 327debf

Browse files
Addressing PR review.
Signed-off-by: Sanghyeok An <[email protected]>
1 parent 77b2051 commit 327debf

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/message-listener-container.adoc

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,13 +31,18 @@ The following example shows how to do so:
3131
public void configureRecordInterceptor(KafkaMessageListenerContainer<Integer, String> container) {
3232
CompositeRecordInterceptor compositeInterceptor;
3333
34-
if (container.getRecordInterceptor() instanceof CompositeRecordInterceptor interceptor) {
34+
RecordInterceptor<Integer, String> previousInterceptor = container.getRecordInterceptor();
35+
if (previousInterceptor instanceof CompositeRecordInterceptor interceptor) {
3536
compositeInterceptor = interceptor;
3637
} else {
3738
compositeInterceptor = new CompositeRecordInterceptor<>();
3839
container.setRecordInterceptor(compositeInterceptor);
3940
}
4041
42+
if (previousInterceptor != null) {
43+
compositeRecordInterceptor.addRecordInterceptor(previousInterceptor);
44+
}
45+
4146
RecordInterceptor<Integer, String> recordInterceptor1 = new RecordInterceptor() {...};
4247
RecordInterceptor<Integer, String> recordInterceptor2 = new RecordInterceptor() {...};
4348

0 commit comments

Comments
 (0)