broker

Documentation

Index

• type Broker
  • func (b *Broker) Send(m Msg)
• type Msg

Types

type Broker

type Broker struct {
	Client sarama.ConsumerGroup
	// contains filtered or unexported fields
}

Broker aaa

var BrokerInstance Broker

BrokerInstance faaa

func (*Broker) Send

func (b *Broker) Send(m Msg)

Send 发送消息

type Msg

type Msg struct {
	Topic   string
	Key     string
	Message string
}

Msg aaa