Producer

Documentation

Index

• Variables
• type Config
  • func (config Config) ParseCli(ctx *cli.Context) Config
• type Producer
  • func Create(ctx context.Context, options Config) (*Producer, error)
  • func (p *Producer) Close() error
  • func (p *Producer) Send(topic string, pkey string, entry sarama.Encoder)

Variables

var CliOptions = libcli.CommonCliOptions(libcli.KafkaBroker, libcli.KafkaVersion)

CliOptions ...

Types

type Config

type Config struct {
	kafka.Config
}

Config ...

func (Config) ParseCli

func (config Config) ParseCli(ctx *cli.Context) Config

ParseCli ...

type Producer

type Producer struct {
	DataCollector     sarama.SyncProducer
	AccessLogProducer sarama.AsyncProducer
}

Producer ...

func Create

func Create(ctx context.Context, options Config) (*Producer, error)

Create ...

func (*Producer) Close

func (p *Producer) Close() error

Close ...

func (*Producer) Send

func (p *Producer) Send(topic string, pkey string, entry sarama.Encoder)

Send ...