KoP (Kafka on Pulsar) 2.7.0.4 更新
KoP 将 Kafka 协议处理插件引入 Pulsar broker。这样一来,Apache Pulsar 就支持原生 Apache Kafka 协议。将 KoP 协议处理插件添加到现有 Pulsar 集群后,用户不用修改代码就可以将现有的 Kafka 应用程序和服务迁移到 Pulsar。这样,Kafka 应用程序就可以使用 Pulsar 的强大功能,例如:
- 利用企业级多租户特性简化运营。
- 避免数据搬迁,简化操作。
- 利用 Apache BookKeeper 和分层存储持久保留事件流。
- 利用 Pulsar Functions 进行无服务器化事件处理。
新版本特性:
- 添加条目格式化程序以在MemoryRecords和ByteBuf之间进行转换;
- 使 ready() 更稳定;
- 添加 KafkaEntryFormatter;
- 修复PulsarEntryFormatter无法正确处理空值的问题
等等