Versions in this module Expand all Collapse all v0 v0.0.2 May 14, 2019 Changes in this version + type KafkaInput struct + Addrs []string + Group string + Message chan []byte + Offset int64 + Topics []string + func NewKafkaInput() *KafkaInput + func (in *KafkaInput) Close() error + func (in *KafkaInput) Init(v interface{}) error + func (in *KafkaInput) Read(p []byte) (cnt int, err error) + func (in *KafkaInput) ReadFromTopic(topic string) + func (in *KafkaInput) ReadWithGroup() error + func (in *KafkaInput) Start() error + func (in *KafkaInput) Version() string + type Producer struct + Addrs []string + MaxProcs int + Message chan []byte + Topic string + func NewProducer() *Producer + func (p *Producer) ChanInfo() string + func (p *Producer) Close() error + func (p *Producer) Init(v interface{}) error + func (p *Producer) LoadConfig(f string) error + func (p *Producer) Start(ctx context.Context) error + func (p *Producer) Version() string + func (p *Producer) Write(msg []byte) (int, error) + func (p *Producer) WriteToTopic(ctx context.Context) error
Go to main page