bigbang489 commented on issue #5807: When CryptoFailureAction is FAIL, after a number of redeliver a message, the message is not move to deadletter topic URL: https://github.com/apache/pulsar/issues/5807#issuecomment-563980138 I used MessageListener interface as below: builder.messageListener(new MessageListener<byte[]>() { private static final long serialVersionUID = 1L; @Override public void received(Consumer<byte[]> consumer, Message<byte[]> msg) { try { if(logger.isDebugEnabled()) { logger.debug("Received msgId: " + BinaryUtil.bytesToHex(msg.getMessageId().toByteArray())+ ", topic: " + msg.getTopicName()); } msgHandler.processMessage(resultConvertor.convert(msg)); } catch (Exception e) { logger.error(ThrowableUtil.trace(e)); } } }); All the decrypted and undecrypted messages are processed in the same way with no error
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
