From 5e0bff224275a7591b00dd915b83b33262658e77 Mon Sep 17 00:00:00 2001 From: Cody Kaczynski Date: Mon, 26 Aug 2024 14:59:35 -0400 Subject: [PATCH] fix: specify int32 --- receiver/kafkareceiver/factory.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/receiver/kafkareceiver/factory.go b/receiver/kafkareceiver/factory.go index 7e47a20c8649..a6fe7ace9f74 100644 --- 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")