Categorygithub.com/codingDr/watermill-kafkapkgkafka
package
0.0.0-20221121182729-41b9a32695de
Repository: https://github.com/codingdr/watermill-kafka.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
9
Dependents
0
Files
531 SLOC

# Functions

DefaultKafkaSubscriberConfig creates default kafka.ConfigMap used by Publishers / Subscribers.
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.

# Constants

No description provided by the author

# Structs

Default JSON Marshaler.
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