Versions in this module Expand all Collapse all v0 v0.1.0 Nov 16, 2020 Changes in this version + type ConfluentProducer struct + func NewConfluentProducer(kafkaURLs []string, topic string) (*ConfluentProducer, error) + func (confluent ConfluentProducer) Close() + func (confluent ConfluentProducer) Publish(key, message string) error + type Producer interface + Close func() + Publish func(key, msg string) error + type SaramaProducer struct + func NewSaramaProducer(kafkaURLs []string, topic string) (*SaramaProducer, error) + func (saramaProducer SaramaProducer) Close() + func (saramaProducer SaramaProducer) Publish(key, message string) error + type SegmentioProducer struct + func NewSegmentioProducer(kafkaURLs []string, topic string) (*SegmentioProducer, error) + func (segmentio SegmentioProducer) Close() + func (segmentio SegmentioProducer) Publish(key, message string) error
Go to main page