From 3fad210bda77ba9ca0a7900a13ed996199c7707f Mon Sep 17 00:00:00 2001 From: abhipranay Date: Fri, 10 May 2024 23:35:24 +0200 Subject: [PATCH] fixed JVM's config name corresponding to MaxWaitTime (#2893) 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