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)

Reply via email to