From 9c5ef5bce694a171302eb498452de23ff2f591d7 Mon Sep 17 00:00:00 2001
From: Roman Leventov <leventov.ru@gmail.com>
Date: Mon, 28 Aug 2017 15:36:42 -0500
Subject: [PATCH] Make ByteBufferInputStream.read(byte[], int, int) to follow
 the contract

---
 .../org/apache/kafka/common/utils/ByteBufferInputStream.java   | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java b/clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java
index 094a1a70db01d..1266d4b8c7385 100644
--- a/clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java
+++ b/clients/src/main/java/org/apache/kafka/common/utils/ByteBufferInputStream.java
@@ -37,6 +37,9 @@ public int read() {
     }
 
     public int read(byte[] bytes, int off, int len) {
+        if (len == 0) {
+            return 0;
+        }
         if (!buffer.hasRemaining()) {
             return -1;
         }