eventuate-tram/eventuate-tram-core

Enable subscriber to ignore old messages

cer opened this issue 2 years ago · 0 comments

cer commented 2 years ago

For example, an anonymous subscriber that wants future messages.

Currently, auto.offset.reset=latest

https://github.com/eventuate-foundation/eventuate-messaging-kafka/blob/b7b618dff09401cf12a51b7b59dd4de0d2771e2d/eventuate-messaging-kafka-basic-consumer/src/main/java/io/eventuate/messaging/kafka/basic/consumer/ConsumerPropertiesFactory.java#L15