小编vic*_*cky的帖子

我正在尝试为flume-ng编写一个自定义接收器.我查看了现有的接收器和文档并对其进行了编码.但是,应该接收事件的'process()'方法总是以null结尾.我正在做Event event = channel.take(); 但事件为空.我在日志中看到,当事件仍在通道中时,会重复调用此方法.

有人能指出我正确的方向吗？