kafkago

type DefaultMarshaler struct {
}

type Marshaler interface {
	Marshal(topic string, msg *message.Message) (*kafka.Message, error)
}

type MarshalerUnmarshaler interface {
	Marshaler
	Unmarshaler
}

type Publisher struct {
	// contains filtered or unexported fields
}

type PublisherConfig struct {
	Writer *kafka.Writer

	Brokers []string

	Async bool

	// Marshaler is used to marshal messages from Watermill format into Kafka format.
	Marshaler Marshaler

	// If true then each sent message will be wrapped with Opentelemetry tracing, provided by otelsarama.
	OTELEnabled bool
	Ipv4Only    bool
	Timeout     time.Duration
}

type Subscriber struct {
	// contains filtered or unexported fields
}

type SubscriberConfig struct {
	Brokers []string

	Unmarshaler Unmarshaler

	OverrideReaderConfig kafka.ReaderConfig

	ConsumerGroup string

	NackResendSleep time.Duration

	ReconnectRetrySleep time.Duration

	OTELEnabled bool
}

type Unmarshaler interface {
	Unmarshal(*kafka.Message) (*message.Message, error)
}