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