我正在尝试在flume 1.3版中编写自己的接收器和源。它没有配置文件flume-site.xml。编译我的 java 文件后如何使用这个自定义接收器？
问问题
3194 次
1 回答
4
您需要将带有已编译接收器的 jar 放在某个地方以流式处理 CLASSPATH。在 1.3.1 版本中，只需 lib/ 就足够了。对于较新的版本，您可以选择使用“plugins.d”目录，查看 FLUME-1735 [1] 了解更多详细信息（已在主干中修复，并将成为 1.4.0 的一部分）。
要将水槽配置为实际使用您的接收器，请在配置中使用您的类的完全限定名称（例如 package.ClassName）。例如，如果您的类在包“earth.europe”中并且类名是“WorldSink”，那么您需要使用以下配置片段：
a1.sinks = s1
a1.sinks.s1.type = earth.europe.WorldSink
雅尔切克
链接：
于 2013-01-16T10:28:28.383 回答