Documentation
¶
Index ¶
- func BuildConsumerGroupConfig(conf *Config, initial int64, autoCommitEnable bool) (*sarama.Config, error)
- func BuildProducerConfig(conf Config) (*sarama.Config, error)
- func CheckHealth(ctx context.Context, conf *Config) error
- func CheckTopics(ctx context.Context, conf *Config, topics []string) error
- func GetContextWithMQHeader(header []*sarama.RecordHeader) context.Context
- func GetMQHeaderWithContext(ctx context.Context) ([]sarama.RecordHeader, error)
- func NewConsumerGroup(conf *sarama.Config, addr []string, groupID string) (sarama.ConsumerGroup, error)
- func NewKafkaProducerV2(config *Config, addr []string, topic string) (mq.Producer, error)
- func NewMConsumerGroupV2(ctx context.Context, conf *Config, groupID string, topics []string, ...) (mq.Consumer, error)
- func NewProducer(conf *sarama.Config, addr []string) (sarama.SyncProducer, error)
- type Config
- type TLSConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetContextWithMQHeader ¶ added in v0.0.48
func GetContextWithMQHeader(header []*sarama.RecordHeader) context.Context
GetContextWithMQHeader creates a context from message queue headers.
func GetMQHeaderWithContext ¶ added in v0.0.48
func GetMQHeaderWithContext(ctx context.Context) ([]sarama.RecordHeader, error)
GetMQHeaderWithContext extracts message queue headers from the context.
func NewConsumerGroup ¶
func NewKafkaProducerV2 ¶
func NewMConsumerGroupV2 ¶
func NewProducer ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.