Skip to content

Commit

Permalink
Fixing get functions for output topic and serde classname (apache#14103)
Browse files Browse the repository at this point in the history
(cherry picked from commit b37ef08)
(cherry picked from commit 7046266)
  • Loading branch information
arnarg authored and nicoloboschi committed Mar 9, 2022
1 parent 07abcb9 commit 7ecf51e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions pulsar-functions/instance/src/main/python/contextimpl.py
Original file line number Diff line number Diff line change
Expand Up @@ -139,10 +139,10 @@ def get_input_topics(self):
return list(self.instance_config.function_details.source.inputSpecs.keys())

def get_output_topic(self):
return self.instance_config.function_details.output
return self.instance_config.function_details.sink.topic

def get_output_serde_class_name(self):
return self.instance_config.function_details.outputSerdeClassName
return self.instance_config.function_details.sink.serDeClassName

def callback_wrapper(self, callback, topic, message_id, result, msg):
if result != pulsar.Result.Ok:
Expand Down

0 comments on commit 7ecf51e

Please sign in to comment.