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