kafka

Documentation

Index

• Constants
• type ConsumerRegister
  • func (cr *ConsumerRegister) Close()
  • func (cr *ConsumerRegister) Initialize(brokerList []string)
  • func (cr *ConsumerRegister) RegisterTopicAndHandler(topic string, groupId string, data interface{}, action HandlerFunc) error
• type HandlerFunc
• type KafkaOptions
• type MessageProducer
  • func (md *MessageProducer) Close() error
  • func (md *MessageProducer) Initialize(brokerList []string) (err error)
  • func (md *MessageProducer) SendMessage(topic string, data interface{}, key string) (partition int32, offset int64, sendErr error)

Constants

const (
	Kafka_Topic_Extractor_EventOnChain    = "Kafka_Topic_Extractor_EventOnChain"
	Kafka_Group_RelayCluster_EventOnChain = "Kafka_Group_RelayCluster_EventOnChain"
)

Types

type ConsumerRegister

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

func (*ConsumerRegister) Close

func (cr *ConsumerRegister) Close()

func (*ConsumerRegister) Initialize

func (cr *ConsumerRegister) Initialize(brokerList []string)

func (*ConsumerRegister) RegisterTopicAndHandler

func (cr *ConsumerRegister) RegisterTopicAndHandler(topic string, groupId string, data interface{}, action HandlerFunc) error

type HandlerFunc

type HandlerFunc func(event interface{}) error

type KafkaOptions

type KafkaOptions struct {
	Brokers []string
}

type MessageProducer

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

func (*MessageProducer) Close

func (md *MessageProducer) Close() error

func (*MessageProducer) Initialize

func (md *MessageProducer) Initialize(brokerList []string) (err error)

func (*MessageProducer) SendMessage

func (md *MessageProducer) SendMessage(topic string, data interface{}, key string) (partition int32, offset int64, sendErr error)