Email: liusinan1998@gmail.com

WeChat: Denovo1998

🧜‍♂️ Disaggregated streaming, purpose-built for Apache Pulsar.

Stateless brokers. Shared object storage. One offset truth. No ZooKeeper, no BookKeeper bookies — just your object store and Oxia for coordination. The kind of streaming engine you wish Pulsar shipped with.

• Stateless brokers — add or remove nodes without partition reassignment or lag spikes
• Object storage as the data plane — S3, MinIO, GCS. Zero local disk on brokers
• One canonical address — streamId + offset replaces ledger IDs, entry IDs, and cursor bookkeeping
• Oxia for metadata — linearizable, cloud-native coordination without ZooKeeper operational overhead

• apache/pulsar#24928 feat pip — PIP-448: Topic-level delayed message tracker (memory optimization)
• apache/pulsar#24927, apache/pulsar#24922 feat broker — Topic-level delayed delivery tracking (in-memory manager)
• apache/pulsar#24370, apache/pulsar#23907 improve pip broker — PIP-423: Admin API to acknowledge a single message
• apache/pulsar#23895, apache/pulsar#23896 improve pip client — PIP-405: Enhanced dynamic handling of selective consumers in MultiTopicConsumers
• apache/pulsar#23143, apache/pulsar#23194 improve pip broker — PIP-371: Support for request-reply model (RPC calls)
• apache/pulsar#19566 improve broker — PIP-246: Improve PROTOBUF_NATIVE schema compatibility checks (no avro-protobuf)
• apache/pulsar#17449 fix broker — PIP-236: Fix schema-based consumer creation failure after AUTO_CONSUME subscribe

• apache/pulsar#24739 improve broker — Optimize fine-grained concurrency control for BucketDelayedDeliveryTracker
• apache/pulsar#24372 improve broker — Support consumer-side delayed messages
• apache/pulsar#23609 improve ml — Avoid repetitive nested lock for isMessageDeleted in ManagedCursorImpl
• apache/pulsar#20415 improve broker — Supplement schema ledger if schema ledger is lost
• apache/pulsar#19753 cleanup broker — Remove duplicate code in SchemaRegistryServiceImpl (schema checks)
• apache/pulsar#24770 fix broker — Flaky-test: ExtensibleLoadManagerImplTest.testDisableBroker

• datastax/starlight-for-kafka#124 improve ci netty — Add Netty leak detection reporting to CI and local tests
• datastax/starlight-for-kafka#126 improve entryFormatter — Reduce allocations in PulsarEntryFormatter batch encoding
• datastax/starlight-for-kafka#127 fix bug netty — Complete ResponseCallbackWrapper on encoding failure
• datastax/starlight-for-kafka#128 improve protocol — Add Kafka client quotas support in KoP

• apache/pulsar-java-contrib#6 improve pcip — PCIP-2: Distributed RPC framework implemented by the Pulsar client
• apache/pulsar-java-contrib#12 improve pcip — PCIP-4: Improve delayed RPC message handling in pulsar-rpc

• apache/pulsar-helm-chart#645 feat helm bookkeeper — Add support for BookKeeper indexDirectories configuration