如何在抛出异常的同时添加额外的自定义头以将消息存储在Kafka上的dlq中？

Question

在抛出Exception iam设置使用者应用程序中的头之前，它正在被设置，但它没有被发送到死信主题，死信主题只有内置的头，如'x-Exception-Message'、'x-Origine-Partition'等。也不是我设定的那个。

下面是我的消费者应用程序中的一段代码：

modifiedMessage = MessageBuilder.fromMessage(consumedMessage).setHeader("x-ecode", new Integer(100)).setHeader(BinderHeaders.PARTITION_OVERRIDE,consumedMessage.getHeaders().get(KafkaHeaders.RECEIVED_PARTITION_ID)).build();
System.out.println("error header:"+modifiedMessage.getHeaders().get("x-ecode",Integer.class)); //100
throw new RuntimeException(modifiedMessage.toString());

注意：Iam在spring.cloud.stream.kafka.binder.header=x-ecode下设置我的application.yml中的x代码

Answer 1

您所做的就是创建一个新消息并丢弃它（除了将异常消息设置为它的字符串实现之外）。

这不会修改原始入站消息。

您可以简单地添加一个新的输出绑定，并自己将修改后的消息发送给它。