publisher

Documentation

Overview

Package publisher provides a basic kafka event publisher

Index

• type KafkaPublisher
  • func NewKafkaPublisher(broker []string) *KafkaPublisher
  • func (kp *KafkaPublisher) Publish(topic string, message []byte) error
• type Publisher

Types

type KafkaPublisher

type KafkaPublisher struct {
	// Broker is a list of Kafka brokers
	Broker []string
	// Config is the configuration for the Kafka event source
	Config kafkaconfig.Config
}

KafkaPublisher is a publisher that sends messages to a Kafka topic

func NewKafkaPublisher

func NewKafkaPublisher(broker []string) *KafkaPublisher

NewKafkaPublisher creates a new KafkaPublisher

func (*KafkaPublisher) Publish

func (kp *KafkaPublisher) Publish(topic string, message []byte) error

Publish satisfies the Publisher interface

type Publisher

type Publisher interface {
	Publish(topic string, message []byte) error
}

Publisher is an interface for publishing messages