# Functions
DefaultSaramaSubscriberConfig creates default Sarama config used by Watermill.
DefaultSaramaSyncPublisherConfig ...
FullyQualifiedStructName name returns object name in format [package].[type name].
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.
MessageUUIDFromCtx returns Kafka internal timestamp of the consumed message.
NamedStruct returns the name from a message implementing the following interface: type namedStruct interface { Name() string } It ignores if the value is a pointer or not.
NewMessage ...
NewPublisher creates a new Kafka Publisher.
NewSubscriber creates a new Kafka Subscriber.
NewWithPartitioningMarshaler ...
StructName name returns struct name in format [type name].
# Constants
EventTypeHeaderKey ...
NoSleep can be set to SubscriberConfig.NackResendSleep and SubscriberConfig.ReconnectRetrySleep.
UUIDHeaderKey ...
# Structs
DefaultMarshaler ...
JSONMarshaler ...
Message ...
NoProtoMessageError ...
ProtobufMarshaler ...
Publisher ...
PublisherConfig ...
Subscriber ...
SubscriberConfig ...
# Interfaces
CommandEventMarshaler marshals Commands and Events to Watermill's messages and vice versa.
Marshaler marshals Watermill's message to Kafka message.
MarshalerUnmarshaler ...
Unmarshaler unmarshals Kafka's message to Watermill's message.
# Type aliases
EventType ...
GeneratePartitionKey ...
Metadata ...
PartitionOffset ...
Payload ...