Versions in this module Expand all Collapse all v1 v1.0.0 Nov 25, 2019 Changes in this version + func NewMessageSink(config MessageSinkConfig) (pubsub.MessageSink, error) + func NewMessageSource(config MessageSourceConfig) pubsub.MessageSource + type MessageSinkConfig struct + Broker string + Topic string + type MessageSourceConfig struct + Broker string + ConsumerGroup string + Topic string
Go to main page