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/04/19 14:45:22 UTC

[GitHub] [pulsar] liangyuanpeng commented on issue #15100: [Go, Functions] Panic while goInstance.ackInputMessage

liangyuanpeng commented on issue #15100:
URL: https://github.com/apache/pulsar/issues/15100#issuecomment-1102744573

   
   I have tested it and it's working for me.  
   pulsar version: 2.9.2
   
   produce message:
   ```shell
   bin/pulsar-admin functions localrun --auto-ack true --go /root/gofunction/gofunction --inputs persistent://zerogap/test-nam/in-msgs --output non-persistent://zerogap/test-nam/filtered-msgs --tenant zerogap --namespace test-nam --name test-input-go-function --retain-ordering --retain-key-ordering --user-config '{"custom-data":"12345"}'
   ```
   
   function log:   
   ```shell
   2022/04/19 14:42:55.009 instance.go:431: [error] the logAppender is nil, if you want to use it, please specify `--log-topic` at startup.
   custom-data is 12345Input message in topic is: {"hello":"world"}
   Filtering radar for custom-data: 12345
   map[hello:world]
   ```


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