Merge pull request #5 from cxdy/feat/kafkareceiver-fetch-configurable

fix: specify int32
linode-obs · Aug 26, 2024 · 0f117ff · 0f117ff
2 parents 6edf5fa + 5e0bff2
commit 0f117ff
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/receiver/kafkareceiver/factory.go b/receiver/kafkareceiver/factory.go
@@ -42,11 +42,11 @@ const (
 	defaultAutoCommitInterval = 1 * time.Second
 
 	// default from sarama.NewConfig()
-	defaultMinFetchSize = 1
+	defaultMinFetchSize = int32(1)
 	// default from sarama.NewConfig()
-	defaultDefaultFetchSize = 1048576
+	defaultDefaultFetchSize = int32(1048576)
 	// default from sarama.NewConfig()
-	defaultMaxFetchSize = 0
+	defaultMaxFetchSize = int32(0)
 )
 
 var errUnrecognizedEncoding = fmt.Errorf("unrecognized encoding")