kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mathias Herberts <mathias.herbe...@gmail.com>
Subject Re: Kafka consumer not reconnecting to restarted Kafka node.
Date Wed, 12 Oct 2011 17:54:31 GMT
> Would it be possible to share your Flume source and sink code, or any tips
> with how you created one?

I'll enquire our legal dept to see how this could be done.

Writing a Source/Sink is actually rather straightforward, under the
hood we are sending/receiving serialized thrift flume events.

The source also handles acknowledgements should you need them.


View raw message