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
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