all,
i am using kafka 0.9 with python-kafka v1.1.1. When i try to create a
SimpleConsumer, it throws error as,
File "/usr/lib/python2.7/site-packages/kafka/consumer/simple.py", line
130, in __init__
auto_commit_every_t=auto_commit_every_t)
File "/usr/lib/python2.7/site-packages/kafka/consumer/base.py", line 78,
in __init__
self.fetch_last_known_offsets(partitions)
File "/usr/lib/python2.7/site-packages/kafka/consumer/base.py", line 112,
in fetch_last_known_offsets
check_error(resp)
File "/usr/lib/python2.7/site-packages/kafka/errors.py", line 389, in
check_error
raise response
FailedPayloadsError
Now, this information on the client side is insufficient. I want to see the
server's request logs and analyze it. I checked in these files under logs
dir. controller.log, kafka-request.log, server.log. But none of them shows
any error/debug messages related to the above FailedPayloadsError.
In config/log4j.properties, i have set logging at the highest level as
log4j.rootLogger=INFO, stdout
But still, why kafka doesn't log the request/response that it handles?
thanks,
saravana
