kafka

Documentation

Index

• type Callback
  • func NewCallback(slow bool, c chan<- Message) *Callback
  • func (c *Callback) Callback(msg *sarama.ConsumerMessage, logger *log.Entry) (bool, error)
• type Message
  • func (c *Message) String() string

Types

type Callback

type Callback struct {
	// contains filtered or unexported fields
}

func NewCallback

func NewCallback(slow bool, c chan<- Message) *Callback

func (*Callback) Callback

func (c *Callback) Callback(msg *sarama.ConsumerMessage, logger *log.Entry) (bool, error)

type Message

type Message struct {
	Offset    int64
	TimeStamp time.Time
	Partition int32
}

func (*Message) String

func (c *Message) String() string