adapter

package

v0.0.0-...-c17b661 Latest Latest Go to latest Published: Jul 22, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

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

type KafkaAdapter struct {
	Writer *kafka.Writer
}

func (k *KafkaAdapter) Close() error

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

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