一、下载协议包（要和pulsar版本比较一致）

https://github.com/streamnative/kop/releases?q=2.8.0&expanded=true

二、在pulsar的根目录创建一个protocols目录，将上述包放到这个目录里
三、编辑broker.conf(如果是集群)或者standalone.conf(如果是单机版)
添加几行配置：（第二行要根据实际路径修改）

messagingProtocols=kafka
protocolHandlerDirectory=/root/apache-pulsar-2.8.0/protocols
kafkaListeners=PLAINTEXT://0.0.0.0:9092
brokerEntryMetadataInterceptors=org.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor

修改两个配置：

brokerDeleteInactiveTopicsEnabled=false
allowAutoTopicCreationType=partitioned 

四、重启pulsar。可以看到本机的9092端口就开了。

就可以通过kafka console producer 和consumer或者java程序和pulsar构造出来的"kafka”交换数据了。