天天看點

pulsar相關指令

啟動   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"

繼續閱讀