Hello all

Maybe a silly question. Are there any  suggestions for implementing a DLQ
in my beam pipeline?

Currently I'm using this library https://github.com/tosun-si/asgarde which
is not bad, the only issue I found  is that sometimes it is hard  to use
with GroupIntoBatches or other native transformations.

Then I saw this PR https://github.com/apache/beam/pull/29164/files which I
think is some sort of DLQ support? but I cannot find something on the docs
for that and I am not 100% familiar with all the beam code to understand
very well.

Appreciated your help


Thank you
-Ruben

Reply via email to