[ 
https://issues.apache.org/jira/browse/FLUME-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13491424#comment-13491424
 ] 

Brock Noland commented on FLUME-1502:
-------------------------------------

After thinking last night I am +1 on the passthru source. It's stupid to use 
tcp/ip as Itra-thread communication even if it makes the impl simpler.

However, I am -1 on exposing Transaction to clients. It's a fairly complex 
interface to use and is full of gotchas. For example, with FileChannel if a 
thread fails to call rollback, data can be "delayed" until restart. I think we 
should only expose put and putBatch (or send and sendBatch) via the embedded 
source. This also further solidifies the one channel per embedded agent unless 
we put a channel identifier on the put method which I think is a mistake since 
multiple embedded agents can be created.

Additionally, I think the embedded agent will need to be re-configurable due to 
the MemoryChannel.
                
> Support for running simple configurations embedded in host process
> ------------------------------------------------------------------
>
>                 Key: FLUME-1502
>                 URL: https://issues.apache.org/jira/browse/FLUME-1502
>             Project: Flume
>          Issue Type: Improvement
>    Affects Versions: v1.2.0
>            Reporter: Arvind Prabhakar
>            Assignee: Brock Noland
>         Attachments: embeeded-agent-1.pdf
>
>
> Flume should provide a light-weight embeddable node manager that can be 
> started in process where necessary. This will allow the users to embed 
> light-weight agents within the host process where necessary.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to