Real-time streaming processing for Fukurow reasoning engine. Supports Kafka, NATS, Redis Streams, and RabbitMQ.