Versions in this module Expand all Collapse all v0 v0.0.4 Jul 19, 2022 Changes in this version + const Scheme + func MinimalConfig() *sarama.Config + func OpenSubscription(brokers []string, config *sarama.Config, group string, topics []string, ...) (*pubsub.Subscription, error) + func OpenTopic(brokers []string, config *sarama.Config, topicName string, opts *TopicOptions) (*pubsub.Topic, error) + type SubscriptionOptions struct + KeyName string + WaitForJoin time.Duration + type TopicOptions struct + KeyName string + type URLOpener struct + Brokers []string + Config *sarama.Config + SubscriptionOptions SubscriptionOptions + TopicOptions TopicOptions + func (o *URLOpener) OpenSubscriptionURL(ctx context.Context, u *url.URL) (*pubsub.Subscription, error) + func (o *URLOpener) OpenTopicURL(ctx context.Context, u *url.URL) (*pubsub.Topic, error)
Go to main page