[
https://issues.apache.org/jira/browse/STORM-511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned STORM-511:
--------------------------------------------
Assignee: Sriharsha Chintalapani
> Storm-Kafka spout keeps sending fetch requests with invalid offset
> ------------------------------------------------------------------
>
> Key: STORM-511
> URL: https://issues.apache.org/jira/browse/STORM-511
> Project: Apache Storm
> Issue Type: Bug
> Affects Versions: 0.9.3
> Reporter: Viktor Taranenko
> Assignee: Sriharsha Chintalapani
> Labels: kafka
> Fix For: 0.9.3, 0.9.3-rc2
>
>
> With default behaviour (KafkaConfig.useStartOffsetTimeIfOffsetOutOfRange ==
> true) when Kafka returns the error about offset being out of range,
> storm.kafka.KafkaUtils.fetchMessages tries to fix offset in local scope and
> retry fetch request. But if there are no more messages appeared under that
> specified partition it will never update the PartitionManager, but keep
> sending tons of requests with invalid offset to Kafka broker. On both sides
> Storm and Kafka logs grow extremely quick during that time.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
