[ https://issues.apache.org/jira/browse/KAFKA-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15041588#comment-15041588 ]
ASF GitHub Bot commented on KAFKA-2893: --------------------------------------- GitHub user ZoneMayor opened a pull request: https://github.com/apache/kafka/pull/628 KAFKA-2893: Add a simple non-negative partition seek check You can merge this pull request into a Git repository by running: $ git pull https://github.com/ZoneMayor/kafka trunk-KAFKA-2893 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/628.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #628 ---- commit 95374147a28208d4850f6e73f714bf418935fc2d Author: ZoneMayor <jinxing6...@126.com> Date: 2015-11-27T03:49:34Z Merge pull request #1 from apache/trunk merge commit cec5b48b651a7efd3900cfa3c1fd0ab1eeeaa3ec Author: ZoneMayor <jinxing6...@126.com> Date: 2015-12-01T10:44:02Z Merge pull request #2 from apache/trunk 2015-12-1 commit a119d547bf1741625ce0627073c7909992a20f15 Author: ZoneMayor <jinxing6...@126.com> Date: 2015-12-04T13:42:27Z Merge pull request #3 from apache/trunk 2015-12-04#KAFKA-2893 commit 253769e9441bc0634fd27d00375c5381daf03202 Author: jinxing <jinx...@fenbi.com> Date: 2015-12-04T14:01:42Z KAFKA-2893: Add Negative Partition Seek Check ---- > 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)