diff --git a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java index 684bd2f..be935e2 100644 --- a/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java +++ b/src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java @@ -1179,6 +1179,9 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i } } } + synchronized (KinesisMessageDrivenChannelAdapter.this.consumerInvokers) { + KinesisMessageDrivenChannelAdapter.this.consumerInvokers.remove(this); + } } @Override