Bulk Operation

KAFKA-5156 User Callback Exceptions need to be handled properly

KAFKA-5156 Improve ProcessorStateManager exception handling

KAFKA-5156 Document any changes from this task

KAFKA-5156 Streams should not re-throw if suspending/closing tasks fails

KAFKA-5156 Check exception handling in all streams tests

KAFKA-5156 Double check how we handle exceptions when commits fail

KAFKA-5156 streams are not recovering from LockException during rebalancing

KAFKA-5156 Unexpected state transition Dead to PendingShutdown

KAFKA-5156 Improve exception handling for state stores

KAFKA-5156 Improve exception handling on coordinator interactions

KAFKA-5156 Improve exception handling for StreamsKafkaClient

KAFKA-5156 Improve exception handling on streams client (communication with brokers)

KAFKA-5156 Improve exception handling on consumer path

KAFKA-5156 Improve exception handling on producer path

KAFKA-5156 Improve Streams internal exception handling

KAFKA-5156 Options for handling corrupt data during deserialization

KAFKA-5156 KeyValueStore.put may throw exception unrelated to the current put attempt

KAFKA-5156 Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

KAFKA-5156 State transitions error PARTITIONS_REVOKED to NOT_RUNNING