apachepulsar-函数执行不影响输出

我在这里遵循了手册: pulsar functions

我有一个Java函数声明:

package org.example.test;

import java.util.function.Function;

public class ExclamationFunction implements Function<String, String> {
   @Override
   public String apply(String input) {
       return String.format("%s!", input);
   }
}

./bin/pulsar-admin functions create --classname org.example.test.ExclamationFunction --jar java-function-1.0-SNAPSHOT.jar --inputs my-topic-1 --namespace default --name JavaFunction

然后:

./bin/pulsar-admin functions trigger --tenant public --namespace default --name JavaFunction --triggerValue "test"

现在我使用C中的一些客户机来使用队列,当我阅读消息时,看到的是“test”,而不是“test!”。