diff --git a/authService b/authService new file mode 100755 index 0000000..fcc8f07 Binary files /dev/null and b/authService differ diff --git a/internal/postman.go b/internal/postman.go index 355fc48..9691a9a 100644 --- a/internal/postman.go +++ b/internal/postman.go @@ -11,12 +11,13 @@ import ( ) type AuthPostmanServer struct { - kafkaReader *kafka.Reader ctx context.Context + kafkaReader *kafka.Reader } func NewServer(ctx context.Context, config *config.Config, topic string) *AuthPostmanServer { return &AuthPostmanServer{ + ctx: ctx, kafkaReader: kafka.NewReader(kafka.ReaderConfig{ Topic: topic, Brokers: []string{net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port))}, @@ -25,7 +26,6 @@ func NewServer(ctx context.Context, config *config.Config, topic string) *AuthPo MinBytes: 10e3, // 10KB MaxBytes: 10e6, // 10MB }), - ctx: ctx, } }