Drop kafka_bytestring

1 files changed, 0 insertions, 12 deletions

diff --git a/kafka/util.py b/kafka/util.py
index e95d51d..c6e77fa 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -95,18 +95,6 @@ def group_by_topic_and_partition(tuples):
     return out
 
 
-def kafka_bytestring(s):
-    """
-    Takes a string or bytes instance
-    Returns bytes, encoding strings in utf-8 as necessary
-    """
-    if isinstance(s, six.binary_type):
-        return s
-    if isinstance(s, six.string_types):
-        return s.encode('utf-8')
-    raise TypeError(s)
-
-
 class ReentrantTimer(object):
     """
     A timer that can be restarted, unlike threading.Timer