Searched defs:NewMessageCarrier (Results 1 – 2 of 2) sorted by relevance
51 func NewMessageCarrier(msg *kafka.Message) MessageCarrier { func