when I use pip install python-kafka-logging, it alway get error like:
ERROR: Complete output from command python setup.py egg_info:
ERROR: Traceback (most recent call last):
File "", line 1, in
File "C:\Local\Temp\pip-install-wopvdc79\python-kafka-logging\setup.py", line 6, in
from pip.req import parse_requirements
ModuleNotFoundError: No module named 'pip.req'
----------------------------------------
ERROR: Command "python setup.py egg_info" failed with error code 1 in C:\Local\Temp\pip-install-wopvdc79\python-kafka-logging
I tried to update my pip, but no use.
Finally, i download the projoect, and change the 'setup.py' in line 6:
from "from pip.req import parse_requirements" to:
"try:
from pip._internal.req import parse_requirements
except ImportError:
from pip.req import parse_requirements
"
That can compatible with different pip versions.

`
from kafka.client import KafkaClient
from kafka.producer import SimpleProducer, KeyedProducer
import logging
from kafka.conn import DEFAULT_SOCKET_TIMEOUT_SECONDS

class KafkaHandler(logging.Handler):

def __init__(self, hosts_list, topic, timeout_secs=DEFAULT_SOCKET_TIMEOUT_SECONDS, **kwargs):
    logging.Handler.__init__(self)

    self.kafka_client = KafkaClient(hosts_list, timeout=timeout_secs)
    self.key = kwargs.get("key", None)
    self.kafka_topic_name = topic

    if not self.key:
        self.producer = SimpleProducer(self.kafka_client, **kwargs)
    else:
        self.producer = KeyedProducer(self.kafka_client, **kwargs)

def emit(self, record):
    # drop kafka logging to avoid infinite recursion
    if record.name == 'kafka':
        return
    try:
        # use default formatting
        msg = self.format(record)
        if isinstance(msg, unicode):
            msg = msg.encode("utf-8")

        # produce message
        if not self.key:
            self.producer.send_messages(self.kafka_topic_name, msg)
        else:
            self.producer.send_messages(self.kafka_topic_name, self.key, msg)
    except (KeyboardInterrupt, SystemExit):
        raise
    except:
        self.handleError(record)

def close(self):
    if self.producer is not None:
        self.producer.stop()
    logging.Handler.close(self)

`

when we check the data using kafka tool, there is no message timestamp present

fix setup.py and readme
prepare to package
upload to pypi

error:
Running setup.py egg_info for package python-kafka-logging
Traceback (most recent call last):
File "", line 16, in
File "/tmp/pip-build-root/python-kafka-logging/setup.py", line 23, in
install_requirements = parse_requirements('requirements.txt', None, None, None, uuid.uuid1())
TypeError: parse_requirements() takes at most 4 arguments (5 given)
Complete output from command python setup.py egg_info:
Traceback (most recent call last):

Hello
I use the check_kafka script and I have the following error message, and I do not see where the problem is, below the logging.conf file

[loggers]
keys=root

[handlers]
keys=consoleHandler,fileHandler,kafkaHandler

[formatters]
keys=simpleFormatter,logstashFormatter

[logger_root]
level=DEBUG
handlers=consoleHandler,fileHandler,kafkaHandler
formatter=simpleFormatter

[handler_fileHandler]
class=logging.handlers.WatchedFileHandler
level=DEBUG
formatter=simpleFormatter
args=('/var/log/check_kafka.log', 'a')

[handler_kafkaHandler]
class=python_kafka_logging.KafkaHandler.KafkaLoggingHandler
level=DEBUG
formatter=logstashFormatter
args=("192.168.0.35:2181, 192.168.0.193:2181","apps-openshift")

[handler_consoleHandler]
class=StreamHandler
level=DEBUG
formatter=simpleFormatter
args=(sys.stdout,)

[formatter_simpleFormatter]
format=%(asctime)s - %(levelname)s - %(name)s - %(message)s

[formatter_logstashFormatter]
class=logstash_formatter.LogstashFormatter
format={"extra": {"appName": "myPythonApp", "environment": "AWS-Test"}}

can you help me ?
thanks