dpkp

#!/usr/bin/python

import argparse
import socket
import time

from kafka.conn import BrokerConnection
from kafka.protocol.fetch import FetchRequest_v1