mq

Documentation

Index

• func InitConsumer()
• func InitProducer()
• type KafkaConsumer
  • func (kc *KafkaConsumer) Close() error
  • func (kc *KafkaConsumer) Consume()
• type KafkaProducer
  • func (p *KafkaProducer) Close() error
  • func (p *KafkaProducer) Produce(msg *sarama.ProducerMessage) (int32, int64, error)

Functions

func InitConsumer

func InitConsumer()

InitConsumer 创建一个新的Kafka消费者实例

func InitProducer

func InitProducer()

InitProducer 创建一个新的 Kafka 生产者

Types

type KafkaConsumer

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

var KafkaConsumerHandler *KafkaConsumer

func (*KafkaConsumer) Close

func (kc *KafkaConsumer) Close() error

Close 关闭消费者连接

func (*KafkaConsumer) Consume

func (kc *KafkaConsumer) Consume()

Consume 消费指定主题的消息

type KafkaProducer

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

var KafkaProducerHandler KafkaProducer

func (*KafkaProducer) Close

func (p *KafkaProducer) Close() error

Close 关闭生产者

func (*KafkaProducer) Produce

func (p *KafkaProducer) Produce(msg *sarama.ProducerMessage) (int32, int64, error)

Produce 向 Kafka 主题发送消息