Versions in this module Expand all Collapse all v0 v0.0.1 May 25, 2022 Changes in this version + func AddHeader(key string, value []byte) optparams.Option[kafka.Message] + func ExtractHeaders(msg *kafka.Message) (map[string][]byte, error) + func ExtractKey(msg *kafka.Message) ([]byte, error) + func ExtractTopic(msg *kafka.Message) string + func ExtractValue(msg *kafka.Message) ([]byte, error) + func NewMsg(topic string, value []byte, opts ...optparams.Option[kafka.Message]) *kafka.Message + func WithHeaders(headers map[string][]byte) optparams.Option[kafka.Message] + func WithKey(key []byte) optparams.Option[kafka.Message] + func WithPartition(partition int32) optparams.Option[kafka.Message] + type ConciseMsg struct + Headers map[string][]byte + Key []byte + Topic string + Value []byte + func Extract(msg *kafka.Message) (*ConciseMsg, error) + func (c *ConciseMsg) AsMessage(opts ...optparams.Option[kafka.Message]) *kafka.Message
Go to main page