Skip to content

Consumer does not handle exceptions in commit() #371

@saiwl

Description

@saiwl

my kafka version supports the auto-commit option,as the title shows,i already received messages after auto-commit setting true.But i still get the error below after receiving several messages:
Traceback (most recent call last):
File "/usr/lib64/python2.6/threading.py", line 532, in __bootstrap_inner
self.run()
File "/usr/lib64/python2.6/threading.py", line 484, in run
self.__target(_self.__args, *_self.__kwargs)
File "/usr/lib/python2.6/site-packages/kafka/util.py", line 134, in _timer
self.fn(_self.args, *_self.kwargs)
File "/usr/lib/python2.6/site-packages/kafka/consumer/base.py", line 127, in commit
resps = self.client.send_offset_commit_request(self.group, reqs)
File "/usr/lib/python2.6/site-packages/kafka/client.py", line 474, in send_offset_commit_request
resps = self._send_broker_aware_request(payloads, encoder, decoder)
File "/usr/lib/python2.6/site-packages/kafka/client.py", line 202, in _send_broker_aware_request
raise FailedPayloadsError(failed_payloads)
FailedPayloadsError: [OffsetCommitRequest(topic='syslog', partition=0, offset=34690, metadata=None)]

can you help me?
thanks a lot!

Metadata

Metadata

Assignees

Labels

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions