Skip to content

Commit 3bf423b

Browse files
feat: go upgrade 1.24
1 parent e09c2e1 commit 3bf423b

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

pkg/kafka/config.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,9 @@ type ProducerConfig struct {
9292
type SkipMessageByHeaderFn func(headers []Header) bool
9393

9494
func (c *Config) SetDefaults() {
95+
if c.Logger == nil {
96+
c.Logger = logger.New(c.LogLevel)
97+
}
9598
if c.Consumer.MaxRetry == 0 {
9699
c.Consumer.MaxRetry = 3
97100
}

pkg/kafka/config_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,8 @@ func TestConfig_SetDefaults(t *testing.T) {
6868
if !reflect.DeepEqual(tt.expected.Producer, k.Producer) {
6969
t.Errorf("Expected: %+v, Actual: %+v", tt.expected.Producer, k.Producer)
7070
}
71-
if !reflect.DeepEqual(tt.expected.Logger, k.Logger) {
72-
t.Errorf("Expected: %+v, Actual: %+v", tt.expected.Logger, k.Logger)
71+
if k.Logger == nil {
72+
t.Errorf("Expected Logger to be initialized, but got nil")
7373
}
7474
if !reflect.DeepEqual(tt.expected.LogLevel, k.LogLevel) {
7575
t.Errorf("Expected: %+v, Actual: %+v", tt.expected.LogLevel, k.LogLevel)

0 commit comments

Comments
 (0)