kafka

Documentation

Index

• type Config
  • func (cfg *Config) NewConfig(brokerList []string, topic string) *Config
  • func (cfg *Config) SyncConsumer() error
  • func (cfg *Config) SyncProducer(val string) error

Types

type Config

type Config struct {
	BrokerList []string

	Topic string
	// contains filtered or unexported fields
}

Config kafka连接配置信息

func (*Config) NewConfig

func (cfg *Config) NewConfig(brokerList []string, topic string) *Config

NewConfig 初始化kakfa client

func (*Config) SyncConsumer

func (cfg *Config) SyncConsumer() error

SyncConsumer 订阅

func (*Config) SyncProducer

func (cfg *Config) SyncProducer(val string) error

SyncProducer 异步发送producer