kafka

package

v1.0.21 Latest Latest Go to latest Published: Aug 13, 2025 License: AGPL-3.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

func GetSaramaConfig(cfg *config.Configuration) *sarama.Config

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

func (c *Consumer) Close() error

func (c *Consumer) Subscribe(topic string) (<-chan *message.Message, error)

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

func NewEventPublisher(producer *Producer, cfg *config.Configuration, logger *logger.Logger) *EventPublisher

func (p *EventPublisher) Publish(ctx context.Context, event *events.Event) error

type MessageConsumer interface {
	Subscribe(topic string) (<-chan *message.Message, error)
	Close() error
}

func NewConsumer(cfg *config.Configuration) (MessageConsumer, error)

type Producer struct {
	*kafka.Publisher
}

func NewProducer(cfg *config.Configuration) (*Producer, error)