我正在编写自定义flume源代码和接收器,目前我还没有看到一个最佳的方式来重用现有的flume ng代码。例如,如果不复制/粘贴大量现有代码,我就无法轻松地扩展avrosource类和自定义某些功能。是故意的还是我做错了什么?
628mspwn1#
如果您想要一个接受avro消息的源,那么您只需要自定义avrosource。这将是编写自定义源和接收器的一个令人惊讶的原因。要编写自定义接收器,请遵循自定义接收器文档。自定义源位于同一文档中。顺便问一下,为什么你需要一个自定义的源和接收器?最后,1.4.0刚刚发布——如果可能的话,您应该使用它。
1条答案
按热度按时间628mspwn1#
如果您想要一个接受avro消息的源,那么您只需要自定义avrosource。这将是编写自定义源和接收器的一个令人惊讶的原因。
要编写自定义接收器,请遵循自定义接收器文档。自定义源位于同一文档中。
顺便问一下,为什么你需要一个自定义的源和接收器?
最后,1.4.0刚刚发布——如果可能的话,您应该使用它。