felice
felice copied to clipboard
Felice is a nascent, opinionated Kafka library for Go, in Go
It is a bit difficult to create a `consumer.Message` or `producer.Message` the first time when testing our handlers. It would be nice if we could have some kind of helper...
As a user of `felice`, which is great, by the way, I'd like to test what I'm actually sending, that is, `topic`, `body` and `key`. I am using a mock...
In order to better control the behaviour of the logs and be able for example to send everything that was logged on Error level to Sentry, we need a library...
When a handler panics we need to recover and retry to prevent the service to crash. - recover - log on Error level - retry after the retry delay
We should print a log message when the Consumer starts up. The message should look like: "started kafka consumer on topic foo, partition bar at offset 420"
Curently we only report metrics when `Consumer.handleMessages` has called `HandleMessage` and it has returned a `nil` error. We need to also report metrics on cases where `HandleMessage` returns an error,...