Dead Letter Queue

Introduction

If the dead letter queue function is enabled, EG sends failed events to the specified queue. If disabled, such events will be discarded.

Procedure

1. Log in to the EG console.
2. In the navigation pane, choose Event Subscriptions.
3. Click Create Event Subscription.
4. Click Event Target.
5. In the displayed dialog box, select an event target.
6. Enable Dead Letter Queue and configure the required parameters.
   Figure 1 Configuring a dead letter queue
   

   Table 1 Dead letter queue parameters

   Parameter	Description
   Queue Type	Select a queue type.
   Instance	Select an instance.
   Connection	Select a connection. Only the connection that matches the queue type can be selected.
   Topic	Select a topic. Do not use the same topic as the event target, or EG cannot distinguish successful events from failed ones.

7. Click OK.

Processing Data in the Dead Letter Queue

Perform the following procedure to process the data in the dead letter queue.

1. Log in to the FunctionGraph console. In the navigation pane, choose Functions > Function List.
2. Click Create Function in the upper right. For details, see Creating an Event Function.
   Figure 2 Function list
   

3. Click the created function to go to the details page.
4. Choose Configuration > Triggers and click Create Trigger.
   Figure 3 Creating a trigger
   

5. Set the following parameters:
   • Trigger Type: Select DMS (for Kafka).
   • Instance: Select the same Kafka instance as the dead letter queue.
   • Topic: Select the same topic as the dead letter queue.
   • Batch Size: Set the number of messages to be retrieved from the topic each time. Recommended: 10.
   • Username: Enter the username of the instance if SSL has been enabled for it.
   • Password: Enter the password of the instance if SSL has been enabled for it.

6. Click OK.
7. Click Enable to enable the Kafka trigger.
   Figure 4 Enabling a Kafka trigger
   

8. Compile the logic for processing data in the dead letter queue.
   Figure 5 Data processing logic
   

9. Configure a test event.
   1. Click Configure Test Event.
   2. Select DMS (for Kafka) and click Create.
      Figure 6 Configuring a test event
      
   3. Select the created test event from the drop-down list.
   4. Click Test and then view the execution result.
      Figure 7 Execution result