pulsar为使用apache kafka java客户端api编写的应用程序提供了一个简单的解决方案
在生产者中，如果想不改变原有kafka的代码架构，就切换到pulsar的平台中，那么pulsar adaptor on kafka就变得非常有用了，它可以帮助我们在不改变原有kafka的代码基础上，即可接入pulsar，但是需要注意，相关配置信息需要进行一些调整，例如：地址与topic
需要导入pulsar集成kafka的依赖包，删掉原有kafka-client包
Kafka适配器生产者：
public class KafkaProducerAdaptor { public static void main(String[] args) { Properties properties = new Properties(System.getProperties()); properties.put("bootstrap.servers", "pulsar://node1:6650,node2:6650,node3:6650"); properties.put("acks", "all"); properties