Featured
Data streaming
New 2026
kafka-agent-bridge is a small Python library for developers who already know LangGraph or CrewAI and want Kafka to be the event bus without hand-rolling consumers, retries, idempotency, result publishing, and dead-letter handling. It fills the space between heavyweight streaming-agent platforms and raw framework glue code.
New 2026
Streaming, steerable text 2 video: a Wan2.1-1.3B student distilled with SF DMD that generates video continuously instead of as a fixed clip.
New 2026
Stream-split a model-authored monologue block into a visible thinking channel. Zero-dependency Python filter. 让思考链回到模型自己笔下。
New 2026
article about pattern of accumulating local cache from kafka topic
New 2026
Self-hosted MVC 3D MKV and unencrypted Blu-ray 3D ISO streaming server with SBS, OU, single-eye, anaglyph, and passive 4K row-interleaved HLS output.
New 2026
High-throughput structured data precompression layer (DLL, C) for Windows x64. 3-6× on-the-fly lossless compression, deterministic memory footprint, zero-allocation hot paths — reduces SIEM ingestion costs (Splunk, Datadog, Elastic) at line rate.
New 2026
A Docker Compose Ready .NET 10 sensor data simulator for testing IoT pipelines without real hardware. Generates realistic readings for 15+ industrial and environmental sensor types (weather, pH, ORP, toxic gas, load cell, and more) and streams them to console, file, or MQTT. Useful for testing MQTT brokers, Grafana dashboards, Kaf
New 2026
Real-time time-series anomaly detection: streaming metrics → Redis Streams → two detectors (rolling z-score + Isolation Forest) compared by precision/recall against labeled ground truth, with a live dashboard and alerting. Python.
New 2026
A Rust-native Apache Kafka client for producer, consumer, and admin use cases, built from the Kafka protocol up. It is not a librdkafka wrapper
New 2026
Decode the Robinhood Chain sequencer feed — see transactions before they execute. Offchain Labs' Nitro relay for transport, a fast lazy decoder for everything after.
New 2026
High-performance open-core CDC, projection, and realtime streaming engine for PostgreSQL, MySQL, MongoDB, Neo4j, Kafka, OpenSearch, GraphQL, and WebSockets.
New 2026
Event sourcing for Java that scales horizontally — no global event log, no outbox, no central write bottleneck. DynamoDB/SNS/SQS reference implementation, Spring Boot starters
New 2026
Zero-allocation Rust engine for predictive telemetry anomaly detection using Topological Data Analysis (TDA). Tracks Betti-1 voids and Euler Characteristic Surface gradients across live data streams to detect structural instability before time-series thresholds fire. Secured with AES-256-GCM, HMAC-SHA256 TCP auth, and Prometheus metrics.
New 2026
A sub-50ms real-time conversational AI voice agent featuring full-duplex WebSocket streaming. Built with Silero VAD, Groq (Whisper & LLaMA-3.1), and ElevenLabs TTS for seamless, low-latency audio processing. video demo -- https://www.loom.com/share/4c167ef2716c4b2b8bb8e6a6cb68d3fd
New 2026
A weather event streaming pipeline, built with Rust and Kafka
Other topics
Browse other topics on Trendshift
A
N