On: Issues we've encountered while building a Kafka based data processing pipeline

[sam0x17]

Couldn't the "state" issue be solved simply by enclosing the database save and kafka message send in the same database transaction block and only doing the kafka send if it reaches that part of the code?