Skip to content

Commit

Permalink
chore: lint
Browse files Browse the repository at this point in the history
  • Loading branch information
erayarslan committed Jan 25, 2025
1 parent 2c195c4 commit 2bd5381
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ type Kafka struct {
Balancer string `yaml:"balancer"`
Brokers []string `yaml:"brokers"`
MetadataTopics []string `yaml:"metadataTopics"`
RejectionLog RejectionLog `yaml:"rejectionLog"`
ProducerMaxAttempts int `yaml:"producerMaxAttempts"`
ReadTimeout time.Duration `yaml:"readTimeout"`
WriteTimeout time.Duration `yaml:"writeTimeout"`
Expand All @@ -36,7 +37,6 @@ type Kafka struct {
Compression int8 `yaml:"compression"`
SecureConnection bool `yaml:"secureConnection"`
AllowAutoTopicCreation bool `yaml:"allowAutoTopicCreation"`
RejectionLog RejectionLog `yaml:"rejectionLog"`
}

type RejectionLog struct {
Expand Down
4 changes: 2 additions & 2 deletions kafka/rejection_log_sink_response_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,10 +11,10 @@ import (
)

type RejectionLogSinkResponseHandler struct {
Config config.Kafka
KafkaClient Client
Writer *kafka.Writer
Topic string
Config config.Kafka
}

func (r *RejectionLogSinkResponseHandler) OnInit(ctx *SinkResponseHandlerInitContext) {
Expand Down Expand Up @@ -81,7 +81,7 @@ func NewRejectionLogSinkResponseHandler() SinkResponseHandler {

type RejectionLog struct {
Topic string
Key []byte
Value string
Error string
Key []byte
}

0 comments on commit 2bd5381

Please sign in to comment.