adapter

Documentation

Index

• func NewKafkaAdapter(kafkaBrokers []string, topic string) port.IMessage
• type KafkaAdapter
  • func (k *KafkaAdapter) Close() error
  • func (k *KafkaAdapter) Consume(topic string) (<-chan kafka.Message, error)
  • func (k *KafkaAdapter) Publish(topic string, message string) error

Functions

func NewKafkaAdapter

func NewKafkaAdapter(kafkaBrokers []string, topic string) port.IMessage

Types

type KafkaAdapter

type KafkaAdapter struct {
	Writer *kafka.Writer
}

func (*KafkaAdapter) Close

func (k *KafkaAdapter) Close() error

func (*KafkaAdapter) Consume

func (k *KafkaAdapter) Consume(topic string) (<-chan kafka.Message, error)

func (*KafkaAdapter) Publish

func (k *KafkaAdapter) Publish(topic string, message string) error