exactly-once

Kafka Streams TaskCorruptedException: Fix and Prevent It

Kafka Streams TaskCorruptedException wipes local state and re-restores from the changelog. Here's why it fires under EOS, how to fix it, and how to stop it.