docker-pulsar
官方文档地址： http://pulsar.apache.org/docs/zh-CN/standalone-docker/
- 检查端口是否冲突
netstat -nlt | grep 8080
netstat -nlt | grep 6650
- 在 Docker 中运行 Pulsar
docker run --name pulsar -d --restart=always -it -p 6650:6650 -p 8080:8080 apachepulsar/pulsar:2.7.2 bin/pulsar standalone
-
Pulsar 支持多个客户端： Java、Go、Python 和 C ++。 如果运行的是本地独立集群，则可以使用以下 URL 中的一个与其交互：
- pulsar://localhost:6650
- http://localhost:8080
-
以下示例展示了如何通过 Python 客户端的 API 快速入门 Pulsar。
直接从 PyPI 安装 Pulsar 的 Python 客户端库：
$ pip install pulsar-client
Consume 一条消息
创建 consumer 并订阅 topic：
import pulsar
client = pulsar.Client('pulsar://localhost:6650')
consumer = client.subscribe('my-topic',
subscription_name='my-sub')
while True:
msg = consumer.receive()
print("Received message: '%s'" % msg.data())
consumer.acknowledge(msg)
client.close()
Produce 一条消息
启动 producer，发送测试消息：
import pulsar
client = pulsar.Client('pulsar://localhost:6650')
producer = client.create_producer('my-topic')
for i in range(10):
producer.send(('hello-pulsar-%d' % i).encode('utf-8'))
client.close()
获取 topic 数据
在最简单的示例中，您可以使用curl来获取特定主题的统计信息：
$ curl http://localhost:8080/admin/v2/persistent/public/default/my-topic/stats | python -m json.tool
输出应如下所示：
{
"reason": "Topic not found"
}