Release v0.2.2

• Reduced Kafka producer batch overhead by serializing synchronous batches eagerly and skipping the retry wrapper on the success path
• Restored Kafka send retries for custom retry policies that handle non-KafkaError transient failures
• Fixed async callable serializer detection so serializer objects with lifecycle hooks still serialize to bytes correctly
• Reduced Kafka source checkpoint churn by caching checkpoint payloads until processed offsets advance
• Improved Redis set batch throughput by switching TTL-free batch writes to MSET
• Added Redis stream consumer tuning knobs for batched acknowledgements and optional raw response handling
• Batched Redis stream acknowledgements and normalized byte-backed error payloads so shutdown, cancel, and fail-closed paths preserve cleaner replay metadata
• Reduced repeated xadd(maxlen=..., approximate=True) argument rebuilding in Redis stream sink batches
• Expanded Redis regression coverage for MSET batch writes and batched stream acknowledgements