Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaAppender ¶
type KafkaAppender struct { logger.BaseAppender // contains filtered or unexported fields }
func NewKafkaAppender ¶
func NewKafkaAppender(prod sarama.AsyncProducer, topic, layout string) *KafkaAppender
func (*KafkaAppender) Write ¶
func (k *KafkaAppender) Write(msg []byte)
Click to show internal directories.
Click to hide internal directories.