Skip to content

Commit 092ce5e

Browse files
authored
Fix enterprise integration test (#3946)
1 parent d4c6e0e commit 092ce5e

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

internal/impl/kafka/enterprise/global_redpanda_writer.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,9 @@ func (l *GlobalRedpandaManager) InitWithCustomDetails(pipelineID, logsTopic, sta
133133

134134
// TODO: Enterprise check here?
135135
resBuilder := service.NewResourceBuilder()
136-
resBuilder.SetBenthosLogger(l.fallbackLogger)
136+
if l.fallbackLogger != nil {
137+
resBuilder.SetBenthosLogger(l.fallbackLogger)
138+
}
137139
res, _, err := resBuilder.Build()
138140
if err != nil {
139141
return err
@@ -209,7 +211,9 @@ func (l *GlobalRedpandaManager) InitFromParsedConfig(pConf *service.ParsedConfig
209211
}
210212

211213
resBuilder := service.NewResourceBuilder()
212-
resBuilder.SetBenthosLogger(l.fallbackLogger)
214+
if l.fallbackLogger != nil {
215+
resBuilder.SetBenthosLogger(l.fallbackLogger)
216+
}
213217
res, _, err := resBuilder.Build()
214218
if err != nil {
215219
return err

0 commit comments

Comments
 (0)