Hi, folks,
I create a issue here, and found that BeamKafkaTable doesn't support all
configs of KafkaIO, such as commitOffsetsInFinalize.
Who can give me any details of that?

https://github.com/apache/beam/issues/27625

Reply via email to