What happened?

Introduced in 9cbdda1 so this is affecting the 2.58 beam release. The Dataflow v2 Runner uses this version for Kafka by default.

Since this can introduce duplicates and is unexpected, marking as P1 and considering to release a patched sdk version to address it.

Issue Priority

Priority: 1 (data loss / total loss of function)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner