Skip to content

Instantly share code, notes, and snippets.

@varlal

varlal/file0.txt

Last active November 11, 2016 06:53
Show Gist options
  • Save varlal/45094a407b5de17f56c56496f2699612 to your computer and use it in GitHub Desktop.
Save varlal/45094a407b5de17f56c56496f2699612 to your computer and use it in GitHub Desktop.
Download ZIP
4ステップで始めてみた最新MQ Pulsar ref: http://qiita.com/varlal/items/bc082b3680b8c858020b
Raw
file0.txt
$ curl -L -O https://github.com/yahoo/pulsar/releases/download/v1.15.2/pulsar-1.15.2-bin.tar.gz
$ tar xvfz pulsar-1.15.2-bin.tar.gz
$ ./pulsar-1.15.2/bin/pulsar standalone
Raw
file1.txt
$ cd pulsar-1.15.2/bin/
$ ./pulsar-client consume -s 'sub' 'persistent://sample/standalone/ns1/my-topic'
Raw
file2.txt
$ cd pulsar-1.15.2/bin/
$ ./pulsar-client produce -m 'Hello Pulsar!' 'persistent://sample/standalone/ns1/my-topic'
Raw
file3.txt
----- got message -----
Hello Pulsar!
2016-11-10 14:49:54,387 - INFO - [main:PulsarClientImpl@302] - Client closing. URL: http://localhost:8080/
2016-11-10 14:49:54,695 - INFO - [main:ConsumerImpl@571] - [persistent://sample/standalone/ns1/my-topic] [sub] Closed consumer
2016-11-10 14:49:54,838 - INFO - [main:CmdConsume@154] - 1 messages successfully consumed
2016-11-10 14:49:54,847 - INFO - [pulsar-client-io-1-1:ClientCnx@94] - [id: 0x9ca18431, L:/127.0.0.1:49311 ! R:localhost.localdomain/127.0.0.1:6650] Disconnected
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment