DefaultSaramaSubscriberConfig creates default Sarama config used by Watermill.

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.

NewPublisher creates a new Kafka Publisher.

NewSubscriber creates a new Kafka Subscriber.

NoSleep can be set to SubscriberConfig.NackResendSleep and SubscriberConfig.ReconnectRetrySleep.

Marshaler marshals Watermill's message to Kafka message.

Unmarshaler unmarshals Kafka's message to Watermill's message.