Versions in this module Expand all Collapse all v1 v1.0.0 May 30, 2025 Changes in this version + func DefaultSaramaConfig() *sarama.Config + type Kafka struct + func New(config any) (*Kafka, error) + func (k *Kafka) Publisher() (message.Publisher, error) + func (k *Kafka) Subscriber(opts ...driver.SubscriberOption) (message.Subscriber, error) + type KafkaConfig struct + Brokers []string + InitializeTopicDetails *sarama.TopicDetail + SaramaConfig *sarama.Config + Subscriber struct{ ... } + func NewKafkaConfig() *KafkaConfig
Go to main page