Logging should be improved for the Deduplicator. Currently, a lot of log output is produced in KafkaUtil.offsetsHaveBeenReached because it's part of a loop. This should be avoided. Instead, information about the current offsets in the source topic and the consumed offsets in the sink topic should be logged
Logging should be improved for the Deduplicator. Currently, a lot of log output is produced in
KafkaUtil.offsetsHaveBeenReached
because it's part of a loop. This should be avoided. Instead, information about the current offsets in the source topic and the consumed offsets in the sink topic should be logged