zifengmo commented on issue #21557: URL: https://github.com/apache/pulsar/issues/21557#issuecomment-1818124242
The code of the message builder : TypedMessageBuilder messageBuilder = producer.newMessage().key(key).value(data.toString().getBytes()); CompletableFuture<MessageId> messageIdCompletableFuture= messageBuilder.sendAsync(); And because of this problem, the broker has been rolled back.But it cannot be reproduced locally. I will redeploy it later to check. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
