I've created a Jira ticket [1].

I confirmed it's not caused by Kafka update from 1.0.0 to 2.4.1.

[1] https://issues.apache.org/jira/browse/BEAM-11387

Reply via email to