writer

Documentation

Index

• type Config
• type KafkaWriter
  • func New(producerName string) (*KafkaWriter, error)
  • func (p *KafkaWriter) Shutdown(timeout int)
  • func (p *KafkaWriter) Start()

Types

type Config

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

type KafkaWriter

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

func New

func New(producerName string) (*KafkaWriter, error)

func (*KafkaWriter) Shutdown

func (p *KafkaWriter) Shutdown(timeout int)

func (*KafkaWriter) Start

func (p *KafkaWriter) Start()