[
https://issues.apache.org/jira/browse/FLUME-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14967973#comment-14967973
]
Ralph Goers commented on FLUME-2632:
------------------------------------
I am now running this in production in my environment and it works just fine.
I'd be happy to commit it but that seems a bit strange since I didn't author it
and wasn't part of the review.
> High CPU on KafkaSink
> ---------------------
>
> Key: FLUME-2632
> URL: https://issues.apache.org/jira/browse/FLUME-2632
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: v1.5.1
> Reporter: Gwen Shapira
> Assignee: Gwen Shapira
> Labels: kafka
> Fix For: v1.6.0
>
> Attachments: FLUME-2632-0.patch
>
>
> Reported here: https://github.com/harishreedharan/flume/issues/1
> "I tried flume-ng-kafka-sink and it worked fine. But I noticed that the cpu
> utilization stay at 100% and never dropped down all the time even at the time
> the channel is empty.
> I looked into the source code and found that "process" function in KafkaSink
> always return Status.READY even if no events available in channel. That
> causes the SinkRunner keep running achieving event from channel and get
> nothing.
> Do we need to change to return Status.BACKOFF in "process" function in
> KafkaSink when it notices that there is no events processed in current round?
> So that the SinkRunner has a chance to take a rest when there is no event in
> channel. If this proposal feasible, function "testEmptyChannel" in
> TestKafkaSink also need to be changed. "
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
