error_handling_03.ex

# This is the "top-level" function for my application
def handle_kafka_message(msg) do
  # Try to do the processing
  :ok = process(msg)
  :ok = acknowledge(msg)
  
# Use catch/2 to handle errors, and send message to DLQ
catch kind, error ->
  Datadog.emit("process_message_failure")
  Logger.error("""
  Unexpected error occurred, sending message to DLQ.
  Kind: #{kind}
  Error: #{error}
  """)
  
  :ok = send_to_dlq(msg)
end