Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct { Producer // contains filtered or unexported fields }
func New ¶
func New(c sk.ProducerConfig, options ...OptionFunc) (*Handler, error)
New creates a new kafka producer
type OptionFunc ¶
func WithLogger ¶
func WithLogger(log Logger) OptionFunc
type ProducerMessage ¶
type ProducerMessage struct{}
type SimpleAsyncProducer ¶
type SimpleAsyncProducer struct { sarama.AsyncProducer ProducerMessage }
func (*SimpleAsyncProducer) SendMessage ¶
func (p *SimpleAsyncProducer) SendMessage(msg *sarama.ProducerMessage) error
func (*SimpleAsyncProducer) SendMessages ¶
func (p *SimpleAsyncProducer) SendMessages(msgs []*sarama.ProducerMessage) error
func (*SimpleAsyncProducer) SendWithKey ¶
func (p *SimpleAsyncProducer) SendWithKey(topic string, key, value []byte) error
type SimpleSyncProducer ¶
type SimpleSyncProducer struct { sarama.SyncProducer ProducerMessage }
func (*SimpleSyncProducer) SendWithKey ¶
func (p *SimpleSyncProducer) SendWithKey(topic string, key, value []byte) error
Click to show internal directories.
Click to hide internal directories.