Skip to content

ECDC-3237 Add support to process commands starting at timestamp

Afonso Mukai requested to merge ECDC-3237_add_support_to_process_commands_starting_at_timestamp into main

Created by: danesss

Issue

Fix behaviour when starting/stopping FW job in short sequence https://jira.esss.lu.se/browse/ECDC-3237

Description of work

To be able to start listening for Commands starting at a specific timestamp, we modify CommandListener to optionally be constructed with a timestamp. When the timestamp is defined, the CommandListener's kafka consumer will assign partitions based on offsets, rather than by subscribing to the topic from "now".

Merge request reports