This is probably better posted on the flume dev or users list (
d...@flume.apache.org and u...@flume.apache.org). I suspect you'll get a
better response there (or even the Cloudera community forums as there is
likely some Kite SDK experience there)
I think what you are saying is that you have a mo
Hi,
We are using flume with kafka source. Flume gets json messages from kafka topic
with given morphline file. If any message that has not well formed with
morphline file json structure is added to kafka topic, flume (consumer) always
tries to consume that wrong message. When we looked the kafk
