pointearth opened a new issue #9765:
URL: https://github.com/apache/pulsar/issues/9765


   **Is your enhancement request related to a problem? Please describe.**
   When a message is processed by multiple functions, there is a key 
"__pfn_input_topic__ " in the "__properties__" attribute of the message, but 
this message is only recorded the last topic name. If I don't want the last 
one, I need a middle one, how could I do?
   
   **Describe the solution you'd like**
   use the key "__pfn_input_topic__ " to record all topics in the process 
chain, splite by commas. for example:
   __pfn_input_topic__ 
="presistent://tenanta/anamespace/topic1,presistent://tenanta/anamespace/topic2,presistent://tenanta/anamespace/topic3"
   
   more often, we can add an attribute to the pulsar function, it identifies 
whether or not to add the last topic to the key-value "__pfn_input_topic__ ".
   
   **Describe alternatives you've considered**
   Actually, we can change the mechanism of the "__properties__", it can be a 
list. It must have some limit rules, such as the max element of a Value, and 
the largest size of a value, it should be 2 attributes of the class message.
   
   
   @codelipenghui @sijie


----------------------------------------------------------------
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]


Reply via email to