stream

Documentation

Index

• func NewKafkaClient(cfg Config) (sarama.Client, error)
• type Config
• type EventPublisher
  • func NewEventPublisher(client sarama.Client) *EventPublisher
  • func (ep *EventPublisher) Close()
  • func (ep *EventPublisher) Publish(ctx context.Context, topic topicName, key string, pbMessage proto.Message) error

Functions

func NewKafkaClient

func NewKafkaClient(cfg Config) (sarama.Client, error)

Types

type Config

type Config struct {
	Brokers []string
}

type EventPublisher

type EventPublisher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewEventPublisher

func NewEventPublisher(client sarama.Client) *EventPublisher

func (*EventPublisher) Close

func (ep *EventPublisher) Close()

func (*EventPublisher) Publish

func (ep *EventPublisher) Publish(ctx context.Context, topic topicName, key string, pbMessage proto.Message) error