kafka

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

type ConsumerConfig struct {
	ClientID         string
	BrokerList       string
	BufferSize       int
	ConsumerNum      int
	FlushMessages    int
	FlushFrequency   int
	FlushMaxMessages int
	Timeout          int
	ReturnErrors     bool
}

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

type ConsumerGroupConfig struct {
	BrokerList   string
	BufferSize   int
	ClientID     string
	GroupID      string
	ReturnErrors bool
}

type Message struct {
	Topic     string
	Partition int32
	Offset    int64
	Key       []byte
	Data      []byte
}

type MessageError struct {
	Error     error
	Topic     string
	Timestamp time.Time
	Partition int32
	Offset    int64
	Metadata  interface{}
}

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

type ProducerConfig struct {
	BrokerList       string
	BufferSize       int
	ProducerNum      int
	FlushMessages    int
	FlushFrequency   int
	FlushMaxMessages int
	Timeout          int
	ReturnErrors     bool
}