mq

Documentation

Index

• type KafkaClient
  • func NewKafkaClient(brokers []string, topic, groupID string) *KafkaClient
  • func (k *KafkaClient) Consume(ctx context.Context, handler func(msg kafka.Message) error) error
  • func (k *KafkaClient) Produce(ctx context.Context, key, value []byte) error

Types

type KafkaClient

type KafkaClient struct {
	Brokers []string
	Topic   string
	GroupID string
}

func NewKafkaClient

func NewKafkaClient(brokers []string, topic, groupID string) *KafkaClient

func (*KafkaClient) Consume

func (k *KafkaClient) Consume(ctx context.Context, handler func(msg kafka.Message) error) error

消费消息，handler是业务处理函数

func (*KafkaClient) Produce

func (k *KafkaClient) Produce(ctx context.Context, key, value []byte) error

发送消息