tbkafka

type CGMessage struct {
	Topic     string
	Group     string
	Partition int32
	Offset    int64
	Payload   string
}

type CompressionType int8

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

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

type ConsumerGroupMessage struct {
	Topic         string
	ConsumerGroup string
	Partition     int32
	Offset        int64
	Payload       []byte
	Error         error
}

type ConsumerGroupOption func(*ConsumerGroup) error

type ConsumerMessage struct {
	Headers   []*sarama.RecordHeader // only set if kafka is version 0.11+
	Topic     string
	Partition int32
	Offset    int64
	Payload   []byte
	Error     error
}

type ConsumerOption func(*Consumer) error

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

type ProducerMessage struct {
	//topic
	Topic string
	// The partitioning key for this message. Pre-existing Encoders include
	// StringEncoder and ByteEncoder.
	Key sarama.Encoder
	//Payload to produce.
	Payload []byte
	// The headers are key-value pairs that are transparently passed
	// by Kafka between producers and consumers.
	Headers []sarama.RecordHeader
	//Custom data which will be enqueued FailedQueue if failed,
	//or be enqueued SucceedQueue if succeed.
	Custom interface{}
	//Partition specified by user when OptionManualPartition
	//was set, or returned by broker.
	Partition int32
	//Offset returned by broker.
	Offset int64
	//Error will be set while showing up in FailedQueue.
	Error error
}

type ProducerOption func(*Producer) error

type RequireType int8

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