kafka

Oct 26, 2022

Changes in this version

+ func OpenSubscription(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Subscription, error)

+ func OpenTopic(logger log.Logger, cfg *service.KafkaConfig) (*pubsub.Topic, error)