
Co-founder & CEO of @streamnativeio | @apache_pulsar, @asfbookkeeper. In a previous life: @streamlio @twitter @yahoo
Bay Area
Joined April 2008
- Tweets1.6K
- Following452
- Followers1.4K
- Likes1.9K
Like the simplicity of Managed Agents but don't want to be locked into one model and harness? Try #Orca Agent Engine (@runorcaai).
Pick your harness (Claude, Codex, Pi) and your model. Built-in guardrails let you allow, deny, or require approval and set budgets.
Run it locally or self-host. runorca.ai/
Replying to @runorcaai
Today we're open-sourcing Orca Agent Engine, an open runtime to run and govern managed agents with any harness and any model.
Developer preview 👇
github.com/orca-ae/orca-agen…
Sijie retweeted
Today we're open-sourcing Orca Agent Engine, an open runtime to run and govern managed agents with any harness and any model.
Developer preview 👇
github.com/orca-ae/orca-agen…
1/ @apache_pulsar 5.0 is out, and it's the new LTS.
The milestone: no more partitions. With Scalable Topics, you never have to answer "how many partitions?" again.
7/ Upgrade at your own pace: v4 clients and existing topics keep working, and topics can migrate in place without copying data.
Huge Kudos to @merlimat @lhotari and the entire @apache_pulsar community
read the announcement: pulsar.apache.org/blog/2026/…
As promised — #Ursa and #UFK (Ursa for #ApacheKafka) are now open source, under the lakestream project: openlakestream.org/
We believe streams are foundational to solving real-time context for #AI and #agents. And like tables, streams need a storage standard to solve the interoperability problem between vendors.
That is why we open sourced it, and published the specification alongside the implementation. Both are public.
We would love to work with the community — and with others across the Kafka, Pulsar, and streaming ecosystem — to build this together.
Checkout the github repos:
- Ursa: github.com/openlakestream/ur…
- UFK: github.com/openlakestream/ka…
Sijie retweeted
🚀 Ursa and UFK are now open source.
We’re opening up the core of StreamNative’s next-gen stream storage architecture:
🔹 Ursa — a stream storage engine built around object storage
🔹 UFK — Kafka-compatible streaming with a diskless architecture
🔹 Lakestream API/spec — an open interface for interoperable stream storage
Our thesis: streams need what tables got — an open storage foundation that decouples data from brokers and protocols.
Come build with us. 🌊
hubs.ly/Q04y6-Hh0
#ApacheKafka #ApachePulsar #Ursa #UFK #OpenSource #DataStreaming
Software was built for people. Now agents are becoming the customer.
At the upcoming #DSS2026 I'm sitting down with @hjzhu (former co-founder & CEO of Iterable, founder & CEO of Mithra) on what changes when agents become customers.
If you are interested in data+agent, please join us: eventbrite.com/e/data-stream…
Last week Snowflake launched Datastream — Kafka-compatible streaming built directly into the platform. To me that's a strong signal: the industry now agrees streaming and the lakehouse belong together, especially for AI agents that need to act on fresh data.
That convergence is exactly the shift we've been building toward. We call it - #Lakestream.
AI agents can't act on yesterday's data. They need the latest events — seconds old — sitting next to the full history that gives them meaning, governed enough to trust. That's real-time context, and it's what the classic two-system setup — streaming on one side, the lakehouse on the other, pipelines in between — was never designed to deliver.
A Lakestream unifies the two, end to end on open standards. You produce and consume the live stream through the Kafka API, and you query that same data as an open Apache Iceberg table from any engine. One stream, written once — a low-latency event stream and an open table at the same time. The log that backs the stream is the table, one copy serving the present and the past at once.
The lakehouse merged the lake and the warehouse. The #Lakestream does it one step earlier in the data's life: it merges the stream and the lakehouse — and keeps both sides open.
We wrote up the full thesis 👇
streamnative.io/blog/what-is…
Data Streaming Summit (organized by @streamnativeio) back. October 7–8, San Francisco. 🎉
Same hardcore, community-first conference we've always run. Same room full of practitioners running real-time data infrastructure at real scale. Same bias toward production numbers over keynote theater.
What's new: we're adding two tracks for the era we're actually living in.
→ Data Streaming Engines — the foundation. Pulsar, Kafka, Ursa, Flink, diskless topics, leaderless logs, lakehouse-native storage.
→ Data Streaming for Agents — the bridge. Real-time context, durable memory, event-driven tool orchestration, agent observability.
→ Agent Harness, Runtime & Governance — the agentic layer. Managed Agents, Agent Executor, Deep Agents, and many in-house runtimes enterprises are quietly building.
Here's the thing: the agent community is running into problems data infrastructure engineers have been solving for a decade — durable state, event ordering, replayable history, observability at scale. They're building the same layer of the stack from opposite ends.
With Current now part of IBM, the case for an independent, practitioner-first venue matters more than ever. Same taste. Bigger scope.
CFP is open through June 30. If you're running this in production, come tell the story.
streamnative.io/blog/announc…
Happy Friday. Hope to see you in SF.
Six days ago I said we're a #Kafka company, too. Not an April Fools' joke.
Today: introducing #Lakestream — an architecture where streams are first-class lakehouse primitives alongside tables.
First proof point: a Native #ApacheKafka Service powered by #Ursa. Now in Limited Public Preview. 🧵
🚀 The Native Apache Kafka Service powered by Ursa is now in Limited Public Preview.
Apache Kafka 4.2+ on Ursa. Every topic is a lakehouse table. Up to 95% lower TCO.
🌟 $1,000 credits with code UFK1000 (Apr 7–14).
👉 Sign up: hubs.ly/Q049R9Kr0
📖 Read the announcement: hubs.ly/Q049Rbkt0
#ApacheKafka #Lakestream #Lakehouse #Iceberg #RealTimeAnalytics
📢 "Wait — my Kafka topic IS a table?"
Yes. Streams and tables on the same open storage and catalog. Protocol is a choice of interface, not a choice of data silo.
Apache Kafka 4.2+ fork on Ursa. Every client works, zero code changes. Up to 95% cost reduction at 5 GB/s throughput.
🤔 Joined the waitlist last week? Your access is live.
Didn't? Use code UFK1000 (Apr 7–15) for $1,000 in StreamNative Cloud credits.
🌊 The Lakestream story: streamnative.io/blog/from-st…
✨ Kafka announcement: streamnative.io/blog/ursa-fo…
🤝 Launch partners: streamnative.io/blog/announc…









