authDB/internal/transport/kafka/kafka_reader.go

package kafka

import (
	"github.com/segmentio/kafka-go"
)

type KafkaReader struct {
	reader *kafka.Reader
}

func NewReader(topic string, address ...string) *KafkaReader {
	return &KafkaReader{
		// reader: &kafka.Reader{
		// 	Topic:    topic,
		// 	Balancer: &kafka.LeastBytes{},
		// 	Addr:     kafka.TCP(address...),
		// },
	}
}

func (s *KafkaReader) Close() error {
	return s.reader.Close()
}

func (s *KafkaReader) ReadMessage(key string, value string) error {
	return nil
}