kafka

Documentation

Index

• func KafkaProducerAdapterFactory(adapterConfig *model.ProducerConfig, client secondary.SecondaryAdapterClient) (secondary.SecodaryPort, error)
• type KafkaProducerClient
  • func NewKafkaClient(addr string, topic string) *KafkaProducerClient
  • func (kafkaProducerClient *KafkaProducerClient) Close()

Functions

func KafkaProducerAdapterFactory

func KafkaProducerAdapterFactory(adapterConfig *model.ProducerConfig, client secondary.SecondaryAdapterClient) (secondary.SecodaryPort, error)

Types

type KafkaProducerClient

type KafkaProducerClient struct {
	Client *kafka.Writer
}

func NewKafkaClient

func NewKafkaClient(addr string, topic string) *KafkaProducerClient

Only cosumer client is included for Kafka

func (*KafkaProducerClient) Close

func (kafkaProducerClient *KafkaProducerClient) Close()