chore: fix revive lint

Author: Abdulsametileri

consumer_config.go

@@ -22,7 +22,7 @@ type ConsumerConfig struct {
 	TLS                 *TLSConfig
 	BatchConfiguration  *BatchConfiguration
 	ConsumeFn           ConsumeFn
-	ClientId            string
+	ClientID            string
 	Rack                string
 	LogLevel            LogLevel
 	Reader              ReaderConfig
@@ -34,10 +34,10 @@ type ConsumerConfig struct {
 
 func (cfg *ConsumerConfig) newCronsumerConfig() *kcronsumer.Config {
 	cronsumerCfg := kcronsumer.Config{
-		ClientID: cfg.RetryConfiguration.ClientId,
+		ClientID: cfg.RetryConfiguration.ClientID,
 		Brokers:  cfg.RetryConfiguration.Brokers,
 		Consumer: kcronsumer.ConsumerConfig{
-			ClientID:          cfg.ClientId,
+			ClientID:          cfg.ClientID,
 			GroupID:           cfg.Reader.GroupID,
 			Topic:             cfg.RetryConfiguration.Topic,
 			Cron:              cfg.RetryConfiguration.StartTimeCron,
@@ -89,7 +89,7 @@ type MetricConfiguration struct {
 type RetryConfiguration struct {
 	SASL          *SASLConfig
 	TLS           *TLSConfig
-	ClientId      string
+	ClientID      string
 	StartTimeCron string
 	Topic         string
 	Rack          string
@@ -107,7 +107,7 @@ type BatchConfiguration struct {
 func (cfg *ConsumerConfig) newKafkaDialer() (*kafka.Dialer, error) {
 	dialer := &Dialer{
 		Dialer: &kafka.Dialer{
-			ClientID: cfg.ClientId,
+			ClientID: cfg.ClientID,
 		},
 	}
 

producer_config.go

@@ -30,7 +30,7 @@ type WriterConfig struct {
 type ProducerConfig struct {
 	SASL     *SASLConfig
 	TLS      *TLSConfig
-	ClientId string
+	ClientID string
 	Writer   WriterConfig
 }
 
@@ -70,7 +70,7 @@ func (c ProducerConfig) newKafkaWriter() (*kafka.Writer, error) {
 func (c ProducerConfig) newKafkaTransport() (*kafka.Transport, error) {
 	transport := &Transport{
 		Transport: &kafka.Transport{
-			ClientID: c.ClientId,
+			ClientID: c.ClientID,
 		},
 	}