Documentation
¶
Index ¶
- func Headers2Map(headers []kafka.Header) map[string][]byte
- func HeadersAdd(headers []kafka.Header, key string, val []byte) []kafka.Header
- func HeadersBatchAdd(headers []kafka.Header, needAddHeaders []kafka.Header) []kafka.Header
- func HeadersPrint(headers []kafka.Header)
- func HeadersValue(headers []kafka.Header, key string) []byte
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Headers2Map ¶
func HeadersAdd ¶
func HeadersBatchAdd ¶
func HeadersBatchAdd(headers []kafka.Header, needAddHeaders []kafka.Header) []kafka.Header
func HeadersPrint ¶
func HeadersPrint(headers []kafka.Header)
func HeadersValue ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.