From 68d5f8983d091f4e7867c3864242d4a9727ec1c7 Mon Sep 17 00:00:00 2001 From: Joshua Powers Date: Thu, 16 Nov 2023 07:04:48 -0700 Subject: [PATCH] fix(modules.kafka): Switch to MaxInt for 32-bit support (#1923) fixes: #1921 --- modules/kafka/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/kafka/kafka.go b/modules/kafka/kafka.go index 016509229b..399f17fb70 100644 --- a/modules/kafka/kafka.go +++ b/modules/kafka/kafka.go @@ -52,7 +52,7 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize "KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS": "1", "KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR": "1", "KAFKA_TRANSACTION_STATE_LOG_MIN_ISR": "1", - "KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt64), + "KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt), "KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS": "0", "KAFKA_NODE_ID": "1", "KAFKA_PROCESS_ROLES": "broker,controller",