kadz1993 opened a new issue #7262: URL: https://github.com/apache/pulsar/issues/7262
**Describe the bug** A Python Pulsar Function I've created attempts to send multiple output per one input. When I tried to obtain the output topic within the function, I get an AttributeError stating that the `output` attribute does not exists. Tracing the code led me to [Function_pb2.py](`https://github.com/apache/pulsar/blob/master/pulsar-functions/instance/src/main/python/Function_pb2.py`) which does not have an `output` element, instead the output topic is stored in `sink`. ERROR logged on the function log ``` Traceback (most recent call last): File "/opt/apache-pulsar-2.5.0/instances/python-instance/python_instance.py", line 242, in actual_execution output_object = self.function_class.process(input_object, self.contextimpl) File "/opt/apache-pulsar-2.5.0/download/pulsar_functions/random_tenant/events/AvroBinaryToJson/0/avro_binary_to_json/src/avro_binary_to_json.py", line 50, in process self._output_topic = context.get_output_topic() File "/opt/apache-pulsar-2.5.0/instances/python-instance/contextimpl.py", line 142, in get_output_topic return self.instance_config.function_details.output AttributeError: output ``` **To Reproduce** Steps to reproduce the behavior: 1. A basic function that uses the Context API to get the output topic (self._output_topic = context.get_output_topic()) 2. Registering the function with Pulsar Admin `pulsar-admin functions create --function-config-file config.yml` config.yml: ``` name: AvroBinaryToJson tenant: random_tenant namespace: events py: /pulsar_functions/avro_binary_to_json/avro_binary_to_json.py className: avro_binary_to_json.AvroBinaryToJson inputs: - persistent://random_tenant/input/event.avro output: persistent://random_tenant/events/event_output log-topic: persistent://random_tenant/logging/AvroBinaryToJson ``` **Expected behavior** The output topic defined in the config is assigned to the variable `self._output_topic` so it can be used to send out multiple messages. **Desktop (please complete the following information):** - OS: CentOS 7 ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
