kafkax

Documentation

Index

• type KafkaConf
• type KafkaConsumer
  • func NewKafkaConsumer(c *KafkaConf) *KafkaConsumer
  • func (ms *KafkaConsumer) SubscribeMessage(handler func(ctx context.Context, msg []byte) error)
• type KafkaProducer
  • func NewKafkaProducer(c *KafkaConf) *KafkaProducer
  • func (mq *KafkaProducer) PublishMessage(ctx context.Context, msg []byte) error

Types

type KafkaConf

type KafkaConf struct {
	Username string   `json:"username"`
	Password string   `json:"password"`
	Brokers  []string `json:"brokers"`
	GroupID  string   `json:"group_id"`
	Topic    string   `json:"topic"`
}

type KafkaConsumer

type KafkaConsumer struct {
	glog.Logger
	// contains filtered or unexported fields
}

func NewKafkaConsumer

func NewKafkaConsumer(c *KafkaConf) *KafkaConsumer

func (*KafkaConsumer) SubscribeMessage

func (ms *KafkaConsumer) SubscribeMessage(handler func(ctx context.Context, msg []byte) error)

type KafkaProducer

type KafkaProducer struct {
	glog.Logger
	// contains filtered or unexported fields
}

func NewKafkaProducer

func NewKafkaProducer(c *KafkaConf) *KafkaProducer

func (*KafkaProducer) PublishMessage

func (mq *KafkaProducer) PublishMessage(ctx context.Context, msg []byte) error