Confluent Cloud：Boomi向Kafka发消息时能否自动创建DLQ？DLQ是否仅适用于消费者？

核心结论 #

Boomi的Kafka生产者连接器不支持自动创建死信队列（DLQ）并自动路由失败消息——这和你提到的HTTP Sink连接器（消费者侧组件）的自动DLT功能不同，两者的角色和失败处理逻辑本质上有区别。

死信机制的适用范围澄清 #

死信机制并非只给消费者用：

• 消费者侧的DLT（比如HTTP Sink连接器）是处理消费过程中无法解析/处理的消息，这类场景下连接器作为消费者，能捕获消费错误并路由到DLT，甚至自动创建主题。
• 生产者侧的失败（比如事务提交失败、消息发送超时、权限不足等），本质是消息没能成功写入目标主题，这种情况需要生产者端主动处理失败消息，没法依赖Kafka broker或连接器自动路由。

Boomi场景下的失败消息处理方案 #

针对你用Boomi向Confluent Cloud批量发消息的场景，可通过以下方式实现类似DLQ的效果：

• 利用Boomi错误分支处理：在Boomi流程里加错误分支，捕获Kafka连接器抛出的发送失败异常（比如事务提交失败、网络错误），把失败的消息内容写入提前在Confluent Cloud控制台创建好的死信主题。还可以用Boomi的数据存储临时缓存失败消息，后续通过单独流程重试或批量写入DLQ。
• 提前配置Confluent Cloud死信主题：先在Confluent Cloud里建好专门的死信主题（比如your-target-topic-dlq），确保Boomi连接器有这个主题的写入权限。如果用事务发送，可在Boomi连接器配置里开事务重试，减少临时网络波动导致的失败，重试失败后再转去DLQ。
• 前置校验减少失败：在Boomi流程里加消息校验步骤，提前过滤格式不符合要求的消息，降低发送阶段的失败概率。同时把失败消息的元数据（发送时间、失败原因、原始内容）一起写入DLQ，方便后续排查和重试。

补充说明 #

你提到的HTTP Sink连接器自动创建DLT的逻辑，是因为它是消费者连接器，在消费源主题消息时遇到处理错误，能通过配置errors.deadletterqueue.topic.name这类参数自动创建DLT并转发错误消息。而生产者连接器的核心目标是把消息写入目标主题，失败时没有内置的自动路由逻辑，必须通过流程层面的错误处理来实现DLQ功能。

内容的提问来源于stack exchange，提问作者varsha bharath