kafka

Documentation

Index

• func NewProducer()
• type Consumer
• type ConsumerOptions
• type Meta
• type Producer
• type ProducerGroup
• type ProducerLite
• type ProducerOptions
• type ProducerPro
• type ProducerStd

Functions

func NewProducer

func NewProducer()

Types

type Consumer

type Consumer struct {
}

type ConsumerOptions

type ConsumerOptions struct {
}

type Meta

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

type Producer

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

type ProducerGroup

type ProducerGroup struct {
	Lite *ProducerLite
	Std  *ProducerStd
	Pro  *ProducerPro
}

type ProducerLite

type ProducerLite struct {
}

低一致性:

type ProducerOptions

type ProducerOptions struct {
	// meta
	Meta *sarama.Config

	Group     string
	Topic     string
	Key       string
	Secret    string
	Batch     int64
	Cluster   string
	CreatedAt string
	// contains filtered or unexported fields
}

type ProducerPro

type ProducerPro struct {
}

高一致性:

type ProducerStd

type ProducerStd struct {
}

常规: