Versions in this module Expand all Collapse all v1 v1.2.2 Jul 24, 2024 Changes in this version + type Message struct + func NewMessage(msg *kafka.Message) *Message + func (m *Message) GetHeader(key string) string + func (m *Message) SetHeader(key, val string) + type MessageCarrier struct + func NewMessageCarrier(msg *Message) MessageCarrier + func (m MessageCarrier) Get(key string) string + func (m MessageCarrier) Keys() []string + func (m MessageCarrier) Set(key string, value string)
Go to main page