Add Consumer.consumer_name() API

pulsar/__init__.py

@@ -1428,6 +1428,12 @@ def subscription_name(self):
         """
         return self._consumer.subscription_name()
 
+    def consumer_name(self):
+        """
+        Return the consumer name.
+        """
+        return self._consumer.consumer_name()
+
     def unsubscribe(self):
         """
         Unsubscribe the current consumer from the topic.

src/consumer.cc

@@ -112,6 +112,7 @@ void export_consumer(py::module_& m) {
         .def("topic", &Consumer::getTopic, "return the topic this consumer is subscribed to",
              py::return_value_policy::copy)
         .def("subscription_name", &Consumer::getSubscriptionName, py::return_value_policy::copy)
+        .def("consumer_name", &Consumer::getConsumerName, py::return_value_policy::copy)
         .def("unsubscribe", &Consumer_unsubscribe)
         .def("receive", &Consumer_receive)
         .def("receive", &Consumer_receive_timeout)

tests/pulsar_test.py

@@ -1886,5 +1886,13 @@ def test_regex_subscription(self):
 
         client.close()
 
+    def test_consumer_name(self):
+        client = Client(self.serviceUrl)
+        name = 'my-consumer-name'
+        consumer = client.subscribe('test_consumer_name', 'sub', consumer_name=name)
+        self.assertEqual(consumer.consumer_name(), name)
+        client.close()
+
+
 if __name__ == "__main__":
     main()