[pulsar] branch master updated: fix get topic name for input message (#3384)

[mm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 550bccb  fix get topic name for input message (#3384)
550bccb is described below

commit 550bccb881134a9d4e69a359e6fb0273fb77e47c
Author: Boyang Jerry Peng <je...@gmail.com>
AuthorDate: Fri Jan 18 09:52:36 2019 -0800

    fix get topic name for input message (#3384)
---
 pulsar-functions/instance/src/main/python/python_instance.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-functions/instance/src/main/python/python_instance.py b/pulsar-functions/instance/src/main/python/python_instance.py
index d86173b..575d992 100644
--- a/pulsar-functions/instance/src/main/python/python_instance.py
+++ b/pulsar-functions/instance/src/main/python/python_instance.py
@@ -290,7 +290,7 @@ class PythonInstance(object):
   def message_listener(self, serde, consumer, message):
     # increment number of received records from source
     self.stats.incr_total_received()
-    item = InternalMessage(message, consumer.topic(), serde, consumer)
+    item = InternalMessage(message, message.topic_name(), serde, consumer)
     self.queue.put(item, True)
     if self.atmost_once and self.auto_ack:
       consumer.acknowledge(message)