# Functions

DefaultSaramaSubscriberConfig creates default Sarama config used by Watermill.
No description provided by the author
MessageKeyFromCtx returns Kafka internal key of the consumed message.
MessagePartitionFromCtx returns Kafka partition of the consumed message.
MessagePartitionOffsetFromCtx returns Kafka partition offset of the consumed message.
MessageTimestampFromCtx returns Kafka internal timestamp of the consumed message.
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
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
No description provided by the author
Unmarshaler unmarshals Kafka's message to Watermill's message.

# Type aliases

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