kafka

type DefaultMarshaler struct{}

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

type MarshalerUnmarshaler interface {
	Marshaler
	Unmarshaler
}

type Message = kafka.Message

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

type PublisherConfig struct {
	// Kafka brokers list.
	Brokers []string

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

	// Kafka ConfigMap
	KafkaConfig *kafka.ConfigMap
}

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

type SubscriberConfig struct {
	// Kafka brokers list.
	Brokers []string

	// Unmarshaler is used to unmarshal messages from Kafka format into Watermill format.
	Unmarshaler Unmarshaler

	// Kafka ConfigMap
	KafkaConfig *kafka.ConfigMap

	// ConsumerGroup is the group.id set for kafka.Consumer
	ConsumerGroup string
}

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