Our great sponsors
-
WorkOS
The modern identity platform for B2B SaaS. The APIs are flexible and easy-to-use, supporting authentication, user identity, and complex enterprise features like SSO and SCIM provisioning.
-
InfluxDB
Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.
What about https://github.com/gocelery/gocelery ?
Use the Segment Kafka library, not Sarama, it’s much easier to use https://github.com/segmentio/kafka-go
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.