我正在尝试在flume版本1.3中编写自己的接收器和源代码。它没有配置文件flume-site.xml。编译java文件后，如何使用这个自定义接收器？
yc0p9oo01#
你需要把jar和你编译好的Flume放在某个地方来清除类路径。在版本1.3.1中，只要lib/就足够了。对于较新的版本，您可以选择使用“plugins.d”目录，检查flume-1735[1]以获取更多详细信息（在trunk中修复，将成为1.4.0的一部分）。要将flume配置为实际使用Flume，请在配置中使用类的完全限定名（例如package.classname）。例如，如果类位于包“earth.europe”中，类名为“worldsink”，则需要使用以下配置片段：
a1.sinks = s1 a1.sinks.s1.type = earth.europe.WorldSink
贾尔切克链接：1: https://issues.apache.org/jira/browse/flume-1735
1条答案
按热度按时间yc0p9oo01#
你需要把jar和你编译好的Flume放在某个地方来清除类路径。在版本1.3.1中，只要lib/就足够了。对于较新的版本，您可以选择使用“plugins.d”目录，检查flume-1735[1]以获取更多详细信息（在trunk中修复，将成为1.4.0的一部分）。
要将flume配置为实际使用Flume，请在配置中使用类的完全限定名（例如package.classname）。例如，如果类位于包“earth.europe”中，类名为“worldsink”，则需要使用以下配置片段：
贾尔切克
链接：
1: https://issues.apache.org/jira/browse/flume-1735