Versions in this module Expand all Collapse all v1 v1.0.1 Aug 8, 2019 v1.0.0 Aug 7, 2019 Changes in this version + const NoSleep + const UUIDHeaderKey + func DefaultSaramaSubscriberConfig() *sarama.Config + func DefaultSaramaSyncPublisherConfig() *sarama.Config + func NewPublisher(brokers []string, marshaler Marshaler, overwriteSaramaConfig *sarama.Config, ...) (message.Publisher, error) + func NewSubscriber(config SubscriberConfig, overwriteSaramaConfig *sarama.Config, ...) (message.Subscriber, error) + type DefaultMarshaler struct + func (DefaultMarshaler) Marshal(topic string, msg *message.Message) (*sarama.ProducerMessage, error) + func (DefaultMarshaler) Unmarshal(kafkaMsg *sarama.ConsumerMessage) (*message.Message, error) + type GeneratePartitionKey func(topic string, msg *message.Message) (string, error) + type Marshaler interface + Marshal func(topic string, msg *message.Message) (*sarama.ProducerMessage, error) + type MarshalerUnmarshaler interface + func NewWithPartitioningMarshaler(generatePartitionKey GeneratePartitionKey) MarshalerUnmarshaler + type Publisher struct + func (p *Publisher) Close() error + func (p *Publisher) Publish(topic string, msgs ...*message.Message) error + type Subscriber struct + func (s *Subscriber) Close() error + func (s *Subscriber) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error) + func (s *Subscriber) SubscribeInitialize(topic string) (err error) + type SubscriberConfig struct + Brokers []string + ConsumerGroup string + InitializeTopicDetails *sarama.TopicDetail + NackResendSleep time.Duration + ReconnectRetrySleep time.Duration + func (c SubscriberConfig) Validate() error + type Unmarshaler interface + Unmarshal func(*sarama.ConsumerMessage) (*message.Message, error) Other modules containing this package github.com/ThreeDotsLabs/watermill-kafka/v2 github.com/ThreeDotsLabs/watermill-kafka/v3
Go to main page