深圳php电商网站开发,wordpress 邮件美化,上海千途建站,网页升级访问升级自动跳一、下载协议包#xff08;要和pulsar版本比较一致#xff09;
https://github.com/streamnative/kop/releases?q2.8.0expandedtrue二、在pulsar的根目录创建一个protocols目录#xff0c;将上述包放到这个目录里 三、编辑broker.conf(如果是集群)或者standalone.con…一、下载协议包要和pulsar版本比较一致
https://github.com/streamnative/kop/releases?q2.8.0expandedtrue二、在pulsar的根目录创建一个protocols目录将上述包放到这个目录里 三、编辑broker.conf(如果是集群)或者standalone.conf(如果是单机版) 添加几行配置第二行要根据实际路径修改
messagingProtocolskafka
protocolHandlerDirectory/root/apache-pulsar-2.8.0/protocols
kafkaListenersPLAINTEXT://0.0.0.0:9092
brokerEntryMetadataInterceptorsorg.apache.pulsar.common.intercept.AppendIndexMetadataInterceptor修改两个配置
brokerDeleteInactiveTopicsEnabledfalse
allowAutoTopicCreationTypepartitioned 四、重启pulsar。可以看到本机的9092端口就开了。
就可以通过kafka console producer 和consumer或者java程序和pulsar构造出来的kafka”交换数据了。
