From 14a0508252455caa44c601dd55cd86c40934ff89 Mon Sep 17 00:00:00 2001 From: slaventius Date: Thu, 2 Feb 2023 11:34:41 +0300 Subject: [PATCH] * --- internal/transport/kafka/kafka_reader.go | 17 ++++++++++++----- 1 file changed, 12 insertions(+), 5 deletions(-) diff --git a/internal/transport/kafka/kafka_reader.go b/internal/transport/kafka/kafka_reader.go index 2922541..c290b82 100644 --- a/internal/transport/kafka/kafka_reader.go +++ b/internal/transport/kafka/kafka_reader.go @@ -6,15 +6,22 @@ import ( type KafkaReader struct { reader *kafka.Reader + first string + topic string } func NewReader(topic string, address ...string) *KafkaReader { return &KafkaReader{ - // reader: &kafka.Reader{ - // Topic: topic, - // Balancer: &kafka.LeastBytes{}, - // Addr: kafka.TCP(address...), - // }, + reader: kafka.NewReader(kafka.ReaderConfig{ + Topic: topic, + Brokers: address, + GroupID: "consumer-group-id", // TODO + Partition: 0, // TODO + MinBytes: 10e3, // 10KB + MaxBytes: 10e6, // 10MB + }), + first: address[0], + topic: topic, } }