kafkamod

Documentation

Index

• type Header
• type Message
  • func (m Message) KafkaHeaders() []kafka.Header
  • func (m Message) KafkaTopicPartition() (tp kafka.TopicPartition)
• type TopicPartition

Types

type Header

type Header struct {
	Key   string
	Value []byte
}

type Message

type Message struct {
	TopicPartition TopicPartition
	Value          []byte
	Key            []byte
	Headers        []Header
	Timestamp      time.Time
	Metadata       *string
}

func (Message) KafkaHeaders

func (m Message) KafkaHeaders() []kafka.Header

func (Message) KafkaTopicPartition

func (m Message) KafkaTopicPartition() (tp kafka.TopicPartition)

type TopicPartition

type TopicPartition struct {
	Topic     string
	Partition int32
	Offset    int64
}