This is an automated email from the ASF dual-hosted git repository. markli pushed a commit to branch kafka-bug-fix in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 264af7eed62739edd9d52b1442efa47190e0d213 Author: Mark Li <[email protected]> AuthorDate: Mon Feb 27 03:52:22 2023 -0800 Fix Typo --- .../apache/eventmesh/client/http/producer/EventMeshMessageProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java index fcfcc9659..5ba3f0fea 100644 --- a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java +++ b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java @@ -98,7 +98,7 @@ class EventMeshMessageProducer extends AbstractProducerHttpClient<EventMeshMessa final SendMessageResponseBody.ReplyMessage replyMessage = JsonUtils.parseObject(retObj.getRetMsg(), SendMessageResponseBody.ReplyMessage.class); return EventMeshMessage.builder() - .content(Objects.requireNonNUll(replyMessage, "ReplyMessage must not be null").body) + .content(Objects.requireNonNull(replyMessage, "ReplyMessage must not be null").body) .prop(replyMessage.properties) .topic(replyMessage.topic).build(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
