Skip to content

Commit 62e9325

Browse files
garyrussellartembilan
authored andcommitted
GH-690: Propagate AfterRollbackProcessor to child
Fixes #690 The concurrent container did not propagate its `AfterRollackProcessor` to child `KafkaMessageListenerContainer`s. **cherry-pick to 2.1.x, 2.0.x, 1.3.x** # Conflicts: # spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java
1 parent c4bf579 commit 62e9325

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/ConcurrentMessageListenerContainer.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ protected void doStart() {
160160
container.setApplicationEventPublisher(getApplicationEventPublisher());
161161
}
162162
container.setClientIdSuffix("-" + i);
163+
container.setAfterRollbackProcessor(getAfterRollbackProcessor());
163164
container.start();
164165
this.containers.add(container);
165166
}

0 commit comments

Comments
 (0)