|
@@ -22,7 +22,7 @@ public class TailingEmitter extends AbstractEmitter {
|
|
ConsumerRecordDeserializer deserializer,
|
|
ConsumerRecordDeserializer deserializer,
|
|
Predicate<TopicMessageDTO> filter,
|
|
Predicate<TopicMessageDTO> filter,
|
|
PollingSettings pollingSettings) {
|
|
PollingSettings pollingSettings) {
|
|
- super(new MessagesProcessing(deserializer, filter, true, null), pollingSettings);
|
|
|
|
|
|
+ super(new MessagesProcessing(deserializer, filter, false, null), pollingSettings);
|
|
this.consumerSupplier = consumerSupplier;
|
|
this.consumerSupplier = consumerSupplier;
|
|
this.consumerPosition = consumerPosition;
|
|
this.consumerPosition = consumerPosition;
|
|
}
|
|
}
|