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 <gabr...@apache.org> 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 >
