This is a Go library for efficiently handling streams of messages, i.e., publishing/receiving messages and reacting to them. It is easy to start with and supports message brokers such as Kafka, RabbitMQ, HTTP, and MySQL binlog, suitable for scenarios like real-time data stream processing, distributed transactions, and microservices communication.