我目前正在尝试基于openliberty mpReactiveMessaging功能https://openliberty.io/blog/2019/09/13/microprofile-reactive-messaging.html
为kafka消息实现使用者。给出类似的方法：
@Incoming("greetings")
public CompletionStage <Void> consume(Message<String> greeting ){
throw new RuntimeException("Something really bad happened.");
}
如何为此类异常实现错误处理？默认行为是，使用者在出现第一个异常时停止处理消息，但这并不是导致稳定/可靠实现的原因。
对于https://kafka.apache.org/documentation/#sinkconnectconfigs，有一些属性可以配置死信队列：
- errors.tolerance
- errors.deadletterqueue.topic.name
但是这些不适用于消费者：https://kafka.apache.org/documentation/#consumerconfigs 有什么办法可以使用反应式消息传递在openliberty中工作？