From f0a07e0c647fd3db0f171cfcfe18c4a1cc878dbf Mon Sep 17 00:00:00 2001 From: Mikkel Oscar Lyderik Larsen Date: Tue, 15 Apr 2025 10:59:33 +0200 Subject: [PATCH] Update pkg/collector/nakadi_collector.go MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Paŭlo Ebermann Signed-off-by: Mikkel Oscar Lyderik Larsen --- pkg/collector/nakadi_collector.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/collector/nakadi_collector.go b/pkg/collector/nakadi_collector.go index 13d2db6..12c27a5 100644 --- a/pkg/collector/nakadi_collector.go +++ b/pkg/collector/nakadi_collector.go @@ -93,8 +93,8 @@ func NewNakadiCollector(_ context.Context, nakadiClient nakadi.Nakadi, hpa *auto subscriptionFilter.ConsumerGroup = consumerGroup } - if subscriptionFilter.SubscriptionID == "" && (subscriptionFilter.OwningApplication == "" && len(subscriptionFilter.EventTypes) == 0 && subscriptionFilter.ConsumerGroup == "") { - return nil, fmt.Errorf("either subscription-id or one of [owning-application, event-types, consumer-group] must be specified on the metric") + if subscriptionFilter.SubscriptionID == "" && (subscriptionFilter.OwningApplication == "" || len(subscriptionFilter.EventTypes) == 0 || subscriptionFilter.ConsumerGroup == "") { + return nil, fmt.Errorf("either subscription-id or all of [owning-application, event-types, consumer-group] must be specified on the metric") } return &NakadiCollector{