From d8e8510f4bcbddb2e0bc2e27ee3ebd66114a6047 Mon Sep 17 00:00:00 2001 From: abhipranay Date: Wed, 8 May 2024 11:36:51 +0200 Subject: [PATCH] fixed JVM's config name corresponding to MaxWaitTime Signed-off-by: abhipranay --- config.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/config.go b/config.go index facf76643..f2f197887 100644 --- a/config.go +++ b/config.go @@ -387,7 +387,7 @@ type Config struct { // default is 250ms, since 0 causes the consumer to spin when no events are // available. 100-500ms is a reasonable range for most cases. Kafka only // supports precision up to milliseconds; nanoseconds will be truncated. - // Equivalent to the JVM's `fetch.wait.max.ms`. + // Equivalent to the JVM's `fetch.max.wait.ms`. MaxWaitTime time.Duration // The maximum amount of time the consumer expects a message takes to