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

Hari Shreedharan commented on FLUME-2613:
-----------------------------------------

Yes, so TransactionEventRecord is the parent class of Put. You can get a TER, 
check if it is a Put using instanceOf, if it is, then build an Event (don't 
expose the Put) by grabbing the header and body from the Put, and pass it to 
the verifier. Does that make sense?

> Tool/script for deleting individual message from queue
> ------------------------------------------------------
>
>                 Key: FLUME-2613
>                 URL: https://issues.apache.org/jira/browse/FLUME-2613
>             Project: Flume
>          Issue Type: Improvement
>            Reporter: Charles McLaughlin
>            Assignee: Ashish Paliwal
>            Priority: Minor
>
> We had a situation where one of our Flume agents got stuck on a message due 
> to unexpected format.  To get things moving again, I stopped the Flume agent, 
> moved the file backed channel data out of the way and re-started the Flume 
> agent.  I'd like to pop the bad message from the queue data on disk and 
> ideally there would be a recommended tool/script.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to