BeamKafkaTable doesn't set commitOffsetsInFinalize to KafkaIO reader

2023-07-24 Thread gabrywu
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

Beam High Priority Issue Report (38)

2023-07-24 Thread beamactions
This is your daily summary of Beam's current high priority issues that may need attention. See https://beam.apache.org/contribute/issue-priorities for the meaning and expectations around issue priorities. Unassigned P0 Issues: https://github.com/apache/beam/issues/27625 [Bug]: [SQL] BeamKa

Re: fastavro Cython fixes

2023-07-24 Thread Kenneth Knowles
Just to close the loop on the dev@ archives, is it correct that fastavro 1.8.1 resolves their end and now it is just Beam work left to do? On Mon, Jul 17, 2023 at 7:18 PM Eddie Zhou wrote: > Hi folks, > > I see some active work on https://github.com/apache/beam/issues/27526 for > Cython 3.0 fixe