Versions in this module Expand all Collapse all v1 v1.0.0 Oct 2, 2023 Changes in this version + func EnableKafkaConsumerTestUtil() fx.Option + func HandleMessage(consumerName string, message []byte) + func MessageCollectorOpt() fx.Option + func NewMessageCollectorHandler(collector *MessageCollector) core.ConsumerHandler + func ResetKafkaConsumerGroupOpt() fx.Option + type MessageCollector struct + func NewMessageCollector() *MessageCollector + func (k *MessageCollector) ClearMessages(topic string) + func (k *MessageCollector) Count(topic string) int64 + func (k *MessageCollector) GetMessages(topic string) []string + func (k *MessageCollector) PushMessage(message *core.ConsumerMessage) + type MessageCollectorHandler struct + func (c *MessageCollectorHandler) HandlerFunc(msg *core.ConsumerMessage) + func (c MessageCollectorHandler) Close()