Anton Kedin created BEAM-4199:
---------------------------------

             Summary: [SQL] Add a DLQ support for Pubsub tables
                 Key: BEAM-4199
                 URL: https://issues.apache.org/jira/browse/BEAM-4199
             Project: Beam
          Issue Type: Improvement
          Components: dsl-sql
            Reporter: Anton Kedin


Currently we crash the pipeline if there's any error processing the message 
from the pubsub, including if it has incorrect JSON format, like missing fields 
etc.

Correct solution would be for the user to specify a way to handle the errors, 
and ideally point to a dead-letter-queue where Beam should send the messages it 
could not process.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to