diff --git a/internal/authDB.go b/internal/authDB.go index 783c271..0736cd9 100644 --- a/internal/authDB.go +++ b/internal/authDB.go @@ -23,13 +23,12 @@ import ( ) type AuthDBServer struct { + ctx context.Context kafkaWriter *kafka.KafkaWriter logger *logger.Logger repo *repo.CustomerRepository api.UnimplementedAuthDBServer api.UnimplementedHealthServer - ctx context.Context - id int32 } func NewServer(ctx context.Context, config *config.Config) *AuthDBServer { @@ -46,11 +45,10 @@ func NewServer(ctx context.Context, config *config.Config) *AuthDBServer { } return &AuthDBServer{ + ctx: ctx, repo: repo, kafkaWriter: kafka.NewWriter(ctx, logger, apiKafka.TopicRegistrations, net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port))), logger: logger, - ctx: ctx, - id: 0, } }