Apache Pulsar的协议适配器有哪些类型？

本文共计2517个文字，预计阅读时间需要11分钟。

背景：为了实现平滑、不修改代码、无侵入式迁移应用，使用Pulsar和KoP（Kafka on Pulsar）插件支持Kafka协议。

应用方式：通过在Pulsar上部署KoP插件，实现Kafka协议的兼容。

GitHub地址：https://github.com/streamnative/kop

背景

为了能平滑、不改写代码、无侵入地迁移应用使用pulsar，KoP以插件形式支持Kafka协议。

Github地址：github.com/streamnative/kop

一、Kafka协议适配器KoP

KoP（Kafka on Pulsar）通过在 Pulsar 代理上引入 Kafka 协议处理程序，为 Apache Pulsar 带来了原生的Apache Kafka协议支持。通过将 KoP 协议处理程序添加到您现有的 Pulsar 集群，您可以将现有的 Kafka 应用程序和服务迁移到Pulsar，而无需修改代码。这使 Kafka 应用程序能够利用 Pulsar 的强大功能。

 

KoP 作为 Pulsar协议处理程序插件实现，协议名称为“kafka”，在 Pulsar broker 启动时加载。它通过在Apache Pulsar上提供原生 Kafka 协议支持，这样可以大大降低学习Pulsar的成本。基于KOP方案, 整合两个流行的事件流生态系统软件。使用ApachePulsar 构建真正统一的事件流平台，以加速实时应用程序和服务的开发。