Versions in this module Expand all Collapse all v0 v0.0.1 Nov 28, 2022 Changes in this version + 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)
Go to main page