From 1a9f7e8bf60c506da83c4812a9c94d61316f54c3 Mon Sep 17 00:00:00 2001 From: Gina Maini Date: Wed, 18 Apr 2018 18:34:54 -0400 Subject: [PATCH] Upon killing Group Coordinator, an entire group would fatally crash given a late enough version of the metadata. --- src/kafunk/Versions.fs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) mode change 100644 => 100755 src/kafunk/Versions.fs diff --git a/src/kafunk/Versions.fs b/src/kafunk/Versions.fs old mode 100644 new mode 100755 index 18bbda3..79e0320 --- a/src/kafunk/Versions.fs +++ b/src/kafunk/Versions.fs @@ -47,7 +47,7 @@ let internal byApiVersionResponse (x:ApiVersionsResponse) : ApiKey -> ApiVersion | ApiKey.Produce -> min 3s v | ApiKey.Fetch -> min 5s v | ApiKey.Offset -> min 0s v // TODO: any higher version for offset is currently crashing - | ApiKey.Metadata -> min 5s v + | ApiKey.Metadata -> min 1s v | ApiKey.OffsetCommit -> min 2s v | ApiKey.OffsetFetch -> min 2s v | ApiKey.GroupCoordinator -> min 1s v