package
0.22.0
Repository: https://github.com/thebeatapp/patron.git
Documentation: pkg.go.dev

# Functions

NewAsyncProducer creates a new async producer with default configuration.
NewJSONMessage creates a new message with a JSON encoded body.
NewMessage creates a new message.
Timeouts option for setting the timeouts.
Version option for setting the version.

# Structs

AsyncProducer defines a async Kafka producer.
Message abstraction of a Kafka message.

# Interfaces

Producer interface for Kafka.

# Type aliases

OptionFunc definition for configuring the async producer in a functional way.