[
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 <[email protected]>
Date: 2015-11-27T03:49:34Z
Merge pull request #1 from apache/trunk
merge
commit cec5b48b651a7efd3900cfa3c1fd0ab1eeeaa3ec
Author: ZoneMayor <[email protected]>
Date: 2015-12-01T10:44:02Z
Merge pull request #2 from apache/trunk
2015-12-1
commit a119d547bf1741625ce0627073c7909992a20f15
Author: ZoneMayor <[email protected]>
Date: 2015-12-04T13:42:27Z
Merge pull request #3 from apache/trunk
2015-12-04#KAFKA-2893
commit 253769e9441bc0634fd27d00375c5381daf03202
Author: jinxing <[email protected]>
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)
