sarama

Documentation

Index

• type Consumer
  • func (c *Consumer) Start()
• type Producer
  • func NewProducer(bootstrapServers string) *Producer
  • func (p *Producer) DeliveryReport()
  • func (p *Producer) ProduceAsync(topic string, key string, value string)
  • func (p *Producer) ProduceSync(topic string, key string, value string)
  • func (p *Producer) Wait()

Types

type Consumer

type Consumer struct {
	Servers         string
	Topic           string
	EnablePartition bool
	Message         chan interface{}
	Done            chan bool
}

func (*Consumer) Start

func (c *Consumer) Start()

type Producer

type Producer struct {
	BootstrapServers []string
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(bootstrapServers string) *Producer

func (*Producer) DeliveryReport

func (p *Producer) DeliveryReport()

func (*Producer) ProduceAsync

func (p *Producer) ProduceAsync(topic string, key string, value string)

func (*Producer) ProduceSync

func (p *Producer) ProduceSync(topic string, key string, value string)

func (*Producer) Wait

func (p *Producer) Wait()