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无法正确处理空值的问题 等等