我目前正在尝试基于openliberty mpreactivemessaging功能实现kafka消息的使用者：https://openliberty.io/blog/2019/09/13/microprofile-reactive-messaging.html
给出如下方法：

@Incoming("greetings")
public CompletionStage <Void> consume(Message<String> greeting ){
   throw new RuntimeException("Something really bad happened.");
}

如何为这些类型的异常实现错误处理？默认行为是，使用者在第一个异常时停止处理消息，而这并不是导致稳定/可靠实现的原因。
为了https://kafka.apache.org/documentation/#sinkconnectconfigs 有一些属性可用于配置死信队列：
误差.公差
errors.deadletterqueue.topic.name错误
但这些都不适用于消费者：https://kafka.apache.org/documentation/#consumerconfigs 在openliberty中，有没有任何方法可以使用响应式消息传递来实现这样的功能？