kkafka

Jul 27, 2021

Changes in this version

+ func HeadersBatchAdd(headers []kafka.Header, needAddHeaders []kafka.Header) []kafka.Header

Jul 20, 2021

Changes in this version

+ func Headers2Map(headers []kafka.Header) map[string][]byte

+ func HeadersAdd(headers []kafka.Header, key string, val []byte) []kafka.Header

+ func HeadersPrint(headers []kafka.Header)

+ func HeadersValue(headers []kafka.Header, key string) []byte