kafka

Documentation

Index

• type KafkaListener
  • func NewKafkaListener(config KafkaProcessorConfig, dataProcessor processors.DataProcessor, ...) *KafkaListener
  • func (k *KafkaListener) Name() string
  • func (k *KafkaListener) Start()
  • func (k *KafkaListener) Stop()
• type KafkaProcessorConfig

Types

type KafkaListener

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

func NewKafkaListener

func NewKafkaListener(config KafkaProcessorConfig, dataProcessor processors.DataProcessor, ledgerWriter backends.LedgerWriter) *KafkaListener

func (*KafkaListener) Name

func (k *KafkaListener) Name() string

func (*KafkaListener) Start

func (k *KafkaListener) Start()

func (*KafkaListener) Stop

func (k *KafkaListener) Stop()

type KafkaProcessorConfig

type KafkaProcessorConfig struct {
	Topic   string
	Address string
	GroupId string
}