Sounds like a useful addition. More generally, we might want to move from a
manual wrapper to an automated wrapper that accepts a configuration object.
Reading the code it seems that each configuration parameters will require
coding right now.
Kenn
On Mon, Jul 24, 2023 at 3:04 AM gabrywu wrote:
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
