Code AnalysisIntermediate 60s
At-Least-Once Consumer Duplicate Side Effect
Pseudo-code:
for msg in stream.consume():
if not processed(msg.id):
apply_credit(msg)
mark_processed(msg.id)
ack(msg)
If the consumer crashes after apply_credit but before mark_processed, what happens and how to fix?
Think you can answer under pressure?
Get matched and answer live questions in 3-minute 1v1 battles. Elo ranking, badge tiers and bragging rights on the line.