This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a commit to branch branch-2.5 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 481c7440a2503df972b69be1ce7ca426e34545b0 Author: Sijie Guo <[email protected]> AuthorDate: Wed Mar 4 17:20:36 2020 -0800 [pulsar-proxy] fix logging for published messages (#6474) ### Motivation Proxy-logging fetches incorrect producerId for `Send` command because of that logging always gets producerId as 0 and it fetches invalid topic name for the logging. ### Modification Fixed topic logging by fetching correct producerId for `Send` command. (cherry picked from commit 65cc30317e46e05ac88866944e2a7e9a68c8afbb) --- .../main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java index 8b4fe64..836556c 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ParserProxyHandler.java @@ -117,7 +117,7 @@ public class ParserProxyHandler extends ChannelInboundHandlerAdapter { logging(ctx.channel() , cmd.getType() , "", null); break; } - topicName = TopicName.get(ParserProxyHandler.producerHashMap.get(String.valueOf(cmd.getProducer().getProducerId()) + "," + String.valueOf(ctx.channel().id()))); + topicName = TopicName.get(ParserProxyHandler.producerHashMap.get(String.valueOf(cmd.getSend().getProducerId()) + "," + String.valueOf(ctx.channel().id()))); MessageParser.parseMessage(topicName, -1L, -1L,buffer,(message) -> { messages.add(message);
