mq

Documentation

Index

• type KafkaLogProducer
  • func (k *KafkaLogProducer) InitWriter()
  • func (k *KafkaLogProducer) Write(p []byte) (n int, err error)

Types

type KafkaLogProducer

type KafkaLogProducer struct {
	Topic     string // Kafka topic
	Partition int    // Kafka partition
	Host      string // Kafka broker host
	Port      int    // Kafka broker port
	// contains filtered or unexported fields
}

func (*KafkaLogProducer) InitWriter

func (k *KafkaLogProducer) InitWriter()

InitWriter InitProducer 初始化 Kafka 生产者

func (*KafkaLogProducer) Write

func (k *KafkaLogProducer) Write(p []byte) (n int, err error)