kafka

Documentation

Index

• Constants
• func Init()
• func SendMessage(topic string, data string)
• type KafkaConsumer
  • func (self *KafkaConsumer) Init() error
  • func (self *KafkaConsumer) StartKafkaListen(listenMsg func(*sarama.ConsumerMessage)) error
• type KafkaProducer
  • func (self *KafkaProducer) Close() error
  • func (self *KafkaProducer) Init() error
  • func (self *KafkaProducer) SendMessage(topic string, data []byte) error

Constants

const (
	TopicLogTrace string = "logTrace"
)

Functions

func Init

func Init()

func SendMessage

func SendMessage(topic string, data string)

send message

Types

type KafkaConsumer

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

func (*KafkaConsumer) Init

func (self *KafkaConsumer) Init() error

func (*KafkaConsumer) StartKafkaListen

func (self *KafkaConsumer) StartKafkaListen(listenMsg func(*sarama.ConsumerMessage)) error

注意该方法是非阻塞的，如果调用了该方法，并且没有其他的阻塞方法，记得手动阻塞他

type KafkaProducer

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

func (*KafkaProducer) Close

func (self *KafkaProducer) Close() error

func (*KafkaProducer) Init

func (self *KafkaProducer) Init() error

func (*KafkaProducer) SendMessage

func (self *KafkaProducer) SendMessage(topic string, data []byte) error