- Process more than one record of one task at time : KAFKA-9756 | PR #8358
- EOS Producer could throw illegal state if trying to complete a failed batch after fatal error : KAFKA-9605 | PR #8177
- KIP-450 : Sliding windows
- KIP-612 : end-to-end latency metrics