《Apache Pulsar从入门到实战》系列教程第10讲之Pulsar Adaptors适配器

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