I’ve set up Kafka as the message bus and I’m writing events to an Postgres DB. When I do not use Kafka and let the SimpleEventBus handle event routing I’m able to trigger replay by deleting the tracking token from the token store.
The same does not happen when I use Kafka as the message bus. I’ve got the KafkaMessageSource property set up in my spring profile and I also have a consumer group and group-id, all the properties that the documentation asks to have.
Could you please guide me as to how I have events (stored in an RDBMS) replayed with Kafka? I’m not sure if there is any more config that needs to go in that hasn’t been mentioned in the docs.