本文共 1499 字，大约阅读时间需要 4 分钟。

在  中，之前曾连续两年入选的 Kafka 意外滑铁卢落选，取而代之的是新兴项目 Pulsar，Bossie Awards中对 Pulsar 点评如下：“Pulsar 旨在取代 Apache Kafka 多年的主宰地位。Pulsar在很多情况下提供了比 Kafka 更快的吞吐量和更低的延迟，并为开发人员提供了一组兼容的 API，让他们可以很轻松地从 Kafka 切换到 Pulsar。Pulsar 的最大优点在于它提供了比 Apache Kafka 更简单明了、更健壮的一系列操作功能，特别在解决可观察性、地域复制和多租户方面的问题。在运行大型 Kafka 集群方面感觉有困难的企业可以考虑转向使用 Pulsar。”

Pulsar中文文档：

1，系统环境

a，操作系统   CentOS Linux release 7.6.1810 (Core)  64位，必须确保你的内存是4G以上，双核CPU！否则将无法新建默认命名空间。

b，确保jdk环境已经安装，具体教程请看    

c，确保Python3和对应的pip已经安装，具体教程请看 

2，执行以下命令，启动Pulsar

wget https://archive.apache.org/dist/pulsar/pulsar-2.3.0/apache-pulsar-2.3.0-bin.tar.gz # 下载pulsar安装包tar xvfz apache-pulsar-2.3.0-bin.tar.gz # 解压安装包cd apache-pulsar-2.3.0 # 打开pulsar目录bin/pulsar standalone  # 启动单机pulsarbin/pulsar-client produce my-topic --messages "hello-pulsar" # 发送一条消息

如图，消息已经成功发送 

3，执行命令     pip3 install pulsar-client==2.3.1

4，创建Pulsar消费者监听python3程序 consumer.py

import pulsarclient = pulsar.Client('pulsar://localhost:6650')consumer = client.subscribe('my-topic2', 'my-subscription')while True:    msg = consumer.receive()    try:        print("Received message '{}' id='{}'".format(msg.data(), msg.message_id()))        consumer.acknowledge(msg)    except:        consumer.negative_acknowledge(msg)client.close()

 运行  python3 consumer.py

5， 创建Pulsar生产者python3程序 producer.py

import pulsarclient = pulsar.Client('pulsar://localhost:6650')producer = client.create_producer('my-topic2')for i in range(10):	producer.send(('Hello-%d' % i).encode('utf-8'))client.close()

 运行   python3 producer.py

看到 消费者监听界面，出现如下消息

转载地址：http://jncii.baihongyu.com/