Jesse Anderson created KAFKA-2893:
-------------------------------------
Summary: Add Negative Partition Seek Check
Key: KAFKA-2893
URL: https://issues.apache.org/jira/browse/KAFKA-2893
Project: Kafka
Issue Type: Bug
Components: clients
Affects Versions: 0.9.0.0
Reporter: Jesse Anderson
When adding add seek that is a negative number, there isn't a check. When you
do give a negative number, you get the following output:
{{2015-11-25 13:54:16 INFO Fetcher:567 - Fetch offset null is out of range,
resetting offset}}
Code to replicate:
KafkaConsumer<String, String> consumer = new KafkaConsumer<String,
String>(props);
TopicPartition partition = new TopicPartition(topic, 0);
consumer.assign(Arrays.asList(partition));
consumer.seek(partition, -1);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)