processor

Documentation

Index

• type KafkaProcessor
  • func NewKafkaProcessor(address []string, topic string, partitions []int32, logQueue *queue.LogQueue) *KafkaProcessor
  • func (processor *KafkaProcessor) Close() error
  • func (processor *KafkaProcessor) Run() error

Types

type KafkaProcessor

type KafkaProcessor struct {
	// contains filtered or unexported fields
}

Kafka log processor

func NewKafkaProcessor

func NewKafkaProcessor(address []string, topic string, partitions []int32, logQueue *queue.LogQueue) *KafkaProcessor

New kafka processor function

func (*KafkaProcessor) Close

func (processor *KafkaProcessor) Close() error

Close kafka consumer

func (*KafkaProcessor) Run

func (processor *KafkaProcessor) Run() error

Run to process log