啟動 bin/pulsar standalone
sink 指令 :
bin/pulsar-admin sink localrun \
--className com.yby.pulsar.mail.MailSink \
--archive /Users/mac/work_place/incubator/mail-sink/target/mail-sink-0.1.0.nar\
--tenant public \
--namespace default \
--name mail-sink \
--sink-config-file examples/mail_sink.yml \
--inputs test11111
生産者:
bin/pulsar-client produce persistent://public/default/ruleaction \
--num-produce 1 \
--messages "Hello world"