[
https://issues.apache.org/jira/browse/FLUME-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168744#comment-16168744
]
Jitendra Kandula commented on FLUME-3027:
-----------------------------------------
[~jholoman]
I have noticed an issue in 1.7 with KafkaChannel. When a node is rebalanced and
gets a different partitions to work with than what it has, offset commit
request includes even old partitions resulting in sending stale offset values
to Kafka.
With this change to clear the map I think that is also resolved. Could you
confirm?
> Kafka Channel should clear offsets map after commit
> ---------------------------------------------------
>
> Key: FLUME-3027
> URL: https://issues.apache.org/jira/browse/FLUME-3027
> Project: Flume
> Issue Type: Bug
> Reporter: Jeff Holoman
> Assignee: Jeff Holoman
> Fix For: 1.8.0
>
>
> Currently the channel doesn't clear the TopicPartition / OffsetsAndMetadata
> map after a commit.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
