Assuming you are using Dataflow as your runner, please check https://cloud.google.com/dataflow/docs/guides/read-from-kafka
On Fri, Dec 20, 2024 at 12:03 PM Utkarsh Parekh <utkarsh.s.par...@gmail.com> wrote: > Hello everyone, > > For Python SDK users, what configuration do you use in the beam pipeline > to ensure committing the offset after loading data in BigQuery? > > What's the best approach? > > Utkarsh > > >
