kafka

Consumer events

*kafka.Message - a fetched message.

AssignedPartitions - The assigned partition set for this client following a rebalance. Requires go.application.rebalance.enable

RevokedPartitions - The counter part to AssignedPartitions following a rebalance. AssignedPartitions and RevokedPartitions are symmetrical. Requires go.application.rebalance.enable

PartitionEOF - Consumer has reached the end of a partition. NOTE: The consumer will keep trying to fetch new messages for the partition.

OffsetsCommitted - Offset commit results (when enable.auto.commit is enabled).

Producer events

*kafka.Message - delivery report for produced message. Check .TopicPartition.Error for delivery result.

https://docs.confluent.io/platform/current/clients/confluent-kafka-go/index.html

https://juejin.cn/post/6844903950009778183
https://www.cnblogs.com/cxuanBlog/p/11949238.html
https://docs.confluent.io/clients-confluent-kafka-go/current/overview.html#asynchronous-commits

https://github.com/confluentinc/confluent-kafka-go/issues/610

https://github.com/go-redis/redis/blob/master/internal/pool/pool.go#L257

https://github.com/go-redis/redis/blob/master/internal/pool/pool.go#L163