kafka

package

v0.0.0-...-9db4afe Latest Latest Go to latest Published: Dec 12, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Consumer struct {
	Addrs   []string
	Topic   string
	Offset  int64
	Message chan *[]byte //从这个管道中读取数据
}

一些使用说明: sarame.OffsetNewest int64 = -1 sarame.OffsetOldest int64 = -2

func NewConsumer(addrs []string, topic string, offset int64) *Consumer

func (self *Consumer) ReadFromTopic()

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

func NewProducer(addrs []string, topic string, maxThreads int) *Producer

func (self *Producer) ChanInfo() string

func (self *Producer) Write(msg []byte) (int, error)

func (self *Producer) WriteToTopic() error