data

package
Version: v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 16, 2021 License: MIT Imports: 5 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Record

type Record struct {
	Key, Value     []byte
	Topic          string
	Partition      int32
	Offset         int64
	Timestamp      time.Time     // only set if kafka is version 0.10+, inner message timestamp
	BlockTimestamp time.Time     // only set if kafka is version 0.10+, outer (compressed) block timestamp
	Headers        RecordHeaders // only set if kafka is version 0.11+
	UUID           uuid.UUID
}

func (*Record) RecordKey

func (r *Record) RecordKey() interface{}

func (*Record) RecordValue

func (r *Record) RecordValue() interface{}

func (*Record) String

func (r *Record) String() string

type RecordHeaders added in v1.2.0

type RecordHeaders []*sarama.RecordHeader

func (RecordHeaders) All added in v1.2.0

func (h RecordHeaders) All() []*sarama.RecordHeader

func (RecordHeaders) Read added in v1.2.0

func (h RecordHeaders) Read(name []byte) []byte

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL