Kafka 4.x Queue Semantics in Flink Connector Kafka

2025-08-30 Thread RShekhar Prasad
Hello team, KIP-932 introduces share groups as a new consumption model that provides queue semantics. This directly addresses use cases where: 1. Multiple consumers need to process items efficiently in parallel from a single/multiple topic(s). 2. Messages  need explicit acknowledgment/release (t

[jira] [Created] (FLINK-38307) Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend

2025-08-30 Thread Naci Simsek (Jira)
Naci Simsek created FLINK-38307: --- Summary: Resuming from both savepoints and checkpoints is NOT supported for Changelog State Backend Key: FLINK-38307 URL: https://issues.apache.org/jira/browse/FLINK-38307