You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/09/21 12:38:41 UTC

[GitHub] [pulsar] dionjansen opened a new issue, #17773: [Bug] python function ignores `--forward-source-message-property true`

dionjansen opened a new issue, #17773:
URL: https://github.com/apache/pulsar/issues/17773

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar.
   
   
   ### Version
   
   Pulsar version: 2.10.1
   
   ### Minimal reproduce step
   
   Follow [Pulsar functions quickstart](https://github.com/apache/pulsar/blob/master/site2/website/versioned_docs/version-2.3.0/functions-quickstart.md#writing-and-running-a-new-function). I'm using Docker to run Pulsar standalone:
   
   ### 1. Run pulsar standalone
   
   First, create a new Python file:
   
   ```bash
   $ touch reverse.py
   ```
   
   In that file, add the following:
   
   ```python
   def process(input):
       return input[::-1]
   ```
   
   ```bash
   $ docker run --name pulsar \
     --rm -it \
     -p 6650:6650 \
     -p 8080:8080 \
     --volume `pwd`/reverse.py:/pulsar/reverse.py \
     apachepulsar/pulsar:2.10.1 bin/pulsar standalone
   ```
   
   ### 2. Consume results
   
   ```bash
   $ docker exec -it pulsar bash -c "bin/pulsar-client consume \
     persistent://public/default/forwards \
     --subscription-name test \
     --num-messages 0"
   ```
   
   ### 3. Start the function with `--forward-source-message-property true` (should be default)
   
   ```bash
   $ docker exec -it pulsar bash -c "/pulsar/bin/pulsar-admin functions localrun \
     --py '/pulsar/reverse.py' \
     --classname reverse \
     --inputs persistent://public/default/backwards \
     --output persistent://public/default/forwards \
     --tenant public \
     --namespace default \
     --forward-source-message-property true \
     --name reverse"
   ```
   
   ### 4. Produce some messages with properties
   
   ```bash
   $ docker exec -it pulsar bash -c "/pulsar/bin/pulsar-client produce \
     persistent://public/default/backwards \
     --messages '1 tset,2 tset,3 tset' \
     --properties 'foo=bar'"
   ```
   
   
   
   ### What did you expect to see?
   
   The consumer in step (2) should output the properties produced.
   
   ### What did you see instead?
   
   Instead only the keys `__pfn_input_msg_id__` and `__pfn_input_topic__` are found in the consumed messages.
   
   ```bash
   ----- got message -----
   key:[null], properties:[__pfn_input_msg_id__=CAwQACAA, __pfn_input_topic__=persistent://public/default/backwards], content:test 1
   ----- got message -----
   key:[null], properties:[__pfn_input_msg_id__=CAwQASAA, __pfn_input_topic__=persistent://public/default/backwards], content:test 2
   ----- got message -----
   key:[null], properties:[__pfn_input_msg_id__=CAwQAiAA, __pfn_input_topic__=persistent://public/default/backwards], content:test 3
   ```
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [X] I'm willing to submit a PR!


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

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] github-actions[bot] commented on issue #17773: [Bug] python function ignores `--forward-source-message-property true`

Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #17773:
URL: https://github.com/apache/pulsar/issues/17773#issuecomment-1287582846

   The issue had no activity for 30 days, mark with Stale label.


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

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] github-actions[bot] commented on issue #17773: [Bug] python function ignores `--forward-source-message-property true`

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #17773:
URL: https://github.com/apache/pulsar/issues/17773#issuecomment-1518918866

   The issue had no activity for 30 days, mark with Stale label.


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

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] dionjansen commented on issue #17773: [Bug] python function ignores `--forward-source-message-property true`

Posted by "dionjansen (via GitHub)" <gi...@apache.org>.
dionjansen commented on issue #17773:
URL: https://github.com/apache/pulsar/issues/17773#issuecomment-1480025396

   Would anyone else be interested in a PR for this?


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

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org