-
What about https://github.com/gocelery/gocelery ?
-
InfluxDB
InfluxDB – Built for High-Performance Time Series Workloads. InfluxDB 3 OSS is now GA. Transform, enrich, and act on time series data directly in the database. Automate critical tasks and eliminate the need to move data externally. Download now.
-
Use the Segment Kafka library, not Sarama, it’s much easier to use https://github.com/segmentio/kafka-go
-
-
-
Benthos
Discontinued Fancy stream processing made operationally mundane [Moved to: https://github.com/redpanda-data/connect]
You might want to have a look at https://www.benthos.dev/. It has integrations with many brokers (such as RabbitMQ, Kafka, Redis, NATS etc.) and it's stateless. It provides a builtin DSL for structured message transformations called bloblang. It also handles batching and in-process parallelism, but it doesn't come with anything specific for scaling horizontally, so, depending on your use case, you might need to have some scheduler set up which spins up / down instances as needed.
-
Stream
Stream - Scalable APIs for Chat, Feeds, Moderation, & Video. Stream helps developers build engaging apps that scale to millions with performant and flexible Chat, Feeds, Moderation, and Video APIs and SDKs powered by a global edge network and enterprise-grade infrastructure.