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 f386713..1801a12 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 @@ -671,7 +671,14 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport if (interruptThread) { Thread.currentThread().interrupt(); } - logger.error(error.getMessage(), e); + + if (this.active) { + logger.error(error.getMessage(), e); + } + else { + logger.info(error.getMessage() + " while adapter was inactive", e); + } + throw error; } }