Categorygithub.com/ThreeDotsLabs/watermillmessageinfrastructurekafka
package
0.4.0
Repository: https://github.com/threedotslabs/watermill.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
9
Dependents
1
Files
645 SLOC

# Functions

DefaultSaramaSubscriberConfig creates default Sarama config used by Watermill.
No description provided by the author
NewPublisher creates a new Kafka Publisher.
NewSubscriber creates a new Kafka Subscriber.
No description provided by the author

# Constants

NoSleep can be set to SubscriberConfig.NackResendSleep and SubscriberConfig.ReconnectRetrySleep.
No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

Marshaler marshals Watermill's message to Kafka message.
No description provided by the author
Unmarshaler unmarshals Kafka's message to Watermill's message.

# Type aliases

No description provided by the author