heetch / felice

Felice is a nascent, opinionated Kafka library for Go, in Go
MIT License
20 stars 1 forks source link

Explicit discarded behaviour #66

Closed sixstone-qq closed 3 years ago

sixstone-qq commented 3 years ago

With this change, the consumer configuration is explicit about what will happen when Discarded is called.

In addition to that, it passes the ConsumerGroupSession context to know if the consumer is being canceled by outer context at shutdown.

This is changing the configuration for Discarded signature. To be backwards compatible, returns true in your function configuration.