Hi all I am proposing a point release because 2.8.0 has a critical data bug. The KafkaIO unconditionally adds a "redistribute allowing duplicates" transform to the read path, whether or not a user requested it.
Issue: https://github.com/apache/beam/issues/32196 Fix: https://github.com/apache/beam/pull/32134 Luckily most runners do not support "allowing duplicates" yet so the impact is minimal. However, let's release an SDK without such a surprise lurking in it. Kenn
