Merge pull request #866 from Parsely/bugfix/unpack_form

descriptive error message for buffer decode failures
Parsely · Sep 17, 2018 · 197fb48 · 197fb48
2 parents 286b33d + abc9c38
commit 197fb48
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pykafka/simpleconsumer.py b/pykafka/simpleconsumer.py
@@ -812,6 +812,10 @@ def unlock_partitions(parts):
                     # If the broker dies while we're supposed to stop,
                     # it's fine, and probably an integration test.
                     return
+                except socket.error:
+                    raise ValueError("Failed to decode IO buffer. Ensure that "
+                                     "the KafkaClient's broker_version kwarg "
+                                     "matches the version of the Kafka cluster.")
                 parts_by_error = build_parts_by_error(response, self._partitions_by_id)
                 handle_partition_responses(
                     self._default_error_handlers,