Hello,

is there still a reason to keep Kafka 0.9 support? This unfortunately adds
lot of complexity to KafkaIO implementation.

Kafka 0.9 was released on Nov 2015.

My first shot on removing Kafka 0.9 support would remove second consumer,
which is used for fetching offsets.

WDYT? Is this support worth keeping?

https://github.com/apache/beam/pull/8186

D.

Reply via email to