1 回答

TA貢獻(xiàn)1934條經(jīng)驗(yàn) 獲得超2個(gè)贊
使用encoding/binary包讀取二進(jìn)制數(shù)據(jù)。例如:
package main
import (
? ? "encoding/binary"
? ? "fmt"
? ? "github.com/confluentinc/confluent-kafka-go/kafka"
)
func main() {
? ? headers := []kafka.Header{
? ? ? ? {
? ? ? ? ? ? Key:? ?"requestNum",
? ? ? ? ? ? Value: []byte("\x01\x00\x00\x00"),
? ? ? ? },
? ? ? ? {
? ? ? ? ? ? Key:? ?"retryNum",
? ? ? ? ? ? Value: []byte("\x1c\x00\x00\x00"),
? ? ? ? },
? ? ? ? {
? ? ? ? ? ? Key:? ?"retryDelaySecs",
? ? ? ? ? ? Value: []byte("@\x01\x00\x00"),
? ? ? ? },
? ? }
? ? for _, h := range headers {
? ? ? ? v := binary.LittleEndian.Uint32(h.Value)
? ? ? ? fmt.Printf("%s: %d\n", h.Key, v)
? ? }
}
- 1 回答
- 0 關(guān)注
- 110 瀏覽
添加回答
舉報(bào)