Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerCallback ¶
type ConsumerCallback func(data []byte)
type ConsumerConfig ¶
type ConsumerConfig struct { Brokers []string `json:"brokers"yaml:"brokers"` //Kafka地址 Group string `json:"group"yaml:"group"` //Kafka消费者组 Topics []string `json:"topics"yaml:"topics"` //消费者需要消费的Topic Assignor string `json:"assignor" yaml:"assignor"` //Kafka消费者组分配策略---随机,轮询,严格 Oldest bool `json:"oldest" yaml:"oldest"` //Kafka消费者是否需要从topic开始的offset开始消费 Verbose bool `json:"verbose" yaml:"verbose"` // sarama的日志开关 Consumer sarama.Consumer `json:"-" yaml:"-"` }
func NewConsumer ¶
func NewConsumer(config *ConsumerConfig) *ConsumerConfig
func (*ConsumerConfig) Close ¶
func (c *ConsumerConfig) Close() error
func (*ConsumerConfig) Consume ¶
func (c *ConsumerConfig) Consume(topic string, callback ConsumerCallback)
type ProducerConfig ¶
type ProducerConfig struct { Brokers []string `json:"brokers" yaml:"brokers"` //Kafka地址 Topics []string `json:"topics" yaml:"topics"` //消费者需要消费的Topic Success bool `json:"success" yaml:"success"` RequiredAcks int16 `json:"requiredAcks" yaml:"requiredAcks"` Producer sarama.SyncProducer `json:"-" yaml:"-"` }
func NewProducer ¶
func NewProducer(config *ProducerConfig) *ProducerConfig
func (*ProducerConfig) Close ¶
func (c *ProducerConfig) Close() error
func (*ProducerConfig) Send ¶
func (c *ProducerConfig) Send(topic, data string)
Click to show internal directories.
Click to hide internal directories.