KafkaException if offset value is more than available offsets. #97
Closed
Description
req = FetchRequest(topic='test', partition=0, offset=100, max_bytes=1000000)
here last offset value is 39 in my case so
kafka.send_fetch_request([req])
throwing an exception
Exception message is -
FetchRequest for TopicAndPartition(topic='test', partition=0) failed with errorcode=1
It will be good if we have a KafkaException defined like version 0.7.