[
https://issues.apache.org/jira/browse/KAFKA-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jin xing reassigned KAFKA-2893:
-------------------------------
Assignee: jin xing
> 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
> Assignee: jin xing
>
> 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)
