[
https://issues.apache.org/jira/browse/FLUME-2250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14136376#comment-14136376
]
Gwen Shapira commented on FLUME-2250:
-------------------------------------
Regarding timedHasNext():
Kafka's API is slightly wonky.
You set a "consumer timeout". hasNext() will block until the timeout
(indefinitely by default), and will throw an exception when the timeout is
reached. So the only possible return value is "true".
This is fine when we consume an event at a time, but a problem when trying to
consume batches (where we may block on each event).
So I'm wrapping the Kafka API with behavior that we can use for batching.
> Add support for Kafka Source
> ----------------------------
>
> Key: FLUME-2250
> URL: https://issues.apache.org/jira/browse/FLUME-2250
> Project: Flume
> Issue Type: Sub-task
> Components: Sinks+Sources
> Affects Versions: v1.5.0
> Reporter: Ashish Paliwal
> Priority: Minor
> Attachments: FLUME-2250-0.patch, FLUME-2250-1.patch,
> FLUME-2250-2.patch, FLUME-2250.patch
>
>
> Add support for Kafka Source
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
