Documentation ¶
Index ¶
- func CreateKafkaClient(brokers string, config *sarama.Config) (sarama.Client, error)
- func CreateTopic(client sarama.Client, topic string, partition int32, replica int16) error
- func CustomConsumerGroup(brokers string, group string, config *sarama.Config) (sarama.ConsumerGroup, error)
- func DefaultConsumerConfig() *sarama.Config
- func DefaultConsumerGroup(brokers string, group string) (sarama.ConsumerGroup, error)
- func DefaultProducer(brokers string) (sarama.SyncProducer, error)
- func DefaultProducerConfig() *sarama.Config
- func DeleteConsumerGroup(client sarama.Client, groups []string) error
- func RemoveTopic(client sarama.Client, topics []string) error
- func ResetConsumerGroupOffset(client sarama.Client, group string, allTopic bool, ...) error
- func SetLogger(out zerolog.Logger, saraLog bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateKafkaClient ¶
CreateKafkaClient 创建kafka客户端,使用后需关闭
func CreateTopic ¶
CreateTopic 创建topic
func CustomConsumerGroup ¶
func CustomConsumerGroup(brokers string, group string, config *sarama.Config) (sarama.ConsumerGroup, error)
CustomConsumerGroup 根据传入的config参数创建消费者组
func DefaultConsumerConfig ¶
DefaultConsumerConfig 默认消费者组配置
func DefaultConsumerGroup ¶
func DefaultConsumerGroup(brokers string, group string) (sarama.ConsumerGroup, error)
DefaultConsumerGroup 默认消费者组
func DefaultProducer ¶
func DefaultProducer(brokers string) (sarama.SyncProducer, error)
DefaultProducer 默认生产者
func DefaultProducerConfig ¶
DefaultProducerConfig 默认生产者配置
func RemoveTopic ¶
RemoveTopic 删除topic
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.