docker-pulsar

官方文档地址： http://pulsar.apache.org/docs/zh-CN/standalone-docker/

1. 检查端口是否冲突

netstat -nlt  | grep  8080 
netstat -nlt  | grep  6650

2. 在 Docker 中运行 Pulsar

docker run --name pulsar -d --restart=always -it -p 6650:6650 -p 8080:8080 apachepulsar/pulsar:2.7.2 bin/pulsar standalone

3. Pulsar 支持多个客户端： Java、Go、Python 和 C ++。 如果运行的是本地独立集群，则可以使用以下 URL 中的一个与其交互：

• pulsar://localhost:6650
• http://localhost:8080

4. 以下示例展示了如何通过 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"
}