Merge pull request #14 from 3lvia/bug/TKP-9301_filter_function

TKP-9301 Exported filter class so it can be used outside kafka package
3lvia · Feb 9, 2024 · 61b7239 · 61b7239
2 parents c505e18 + f057ffc
commit 61b7239
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pkg/sfkafkalib/kafka/filter.go b/pkg/sfkafkalib/kafka/filter.go
@@ -2,8 +2,8 @@ package kafka
 
 import "github.com/3lvia/libraries-go/pkg/kafkaclient"
 
-type kafkaFilter struct {
+type Filter struct {
 	keep filterFn
 }
 
-type filterFn func(message *kafkaclient.StreamingMessage) bool
+type filterFn func(m *kafkaclient.StreamingMessage) bool
diff --git a/pkg/sfkafkalib/kafka/kafkaconsumer.go b/pkg/sfkafkalib/kafka/kafkaconsumer.go
@@ -26,7 +26,7 @@ var (
 
 type Consumer struct {
 	logger  *otelzap.Logger
-	filter  *kafkaFilter
+	filter  *Filter
 	tracer  trace.Tracer
 	ctx     context.Context
 	conf    configuration.ConsumerConfig