我有一个简单的Flume代理,具有以下配置:
agent.sources = http-source
agent.sinks = logger-sink
agent.channels = logger-channel
# HTTP Source
###############################
agent.sources.http-source.type = org.apache.flume.source.http.HTTPSource
agent.sources.http-source.channels = logger-channel
agent.sources.http-source.port = 81
# Logger Sink
###############################
agent.sinks.logger-sink.type = logger
agent.sinks.logger-sink.channel = logger-channel
# Channel
###############################
agent.channels.logger-channel.type = memory
agent.channels.logger-channel.capacity = 1000
Flume代理唯一能做的就是通过HTTP Source接收HTTP POST请求并使用Logger Sink记录事件.
我遇到的问题如下:有时当我向Flume代理发送HTTP POST请求时,我需要1-5秒才能看到控制台中的日志.这仅适用于启动Flume代理后发送的第一条消息.发送几条消息后,我立即在控制台中看到日志.
我的问题是:它是Flume的热身问题吗?似乎如果我暂时不发送任何消息,我将再次看到控制台中的日志.
请注意,我使用docker-compose文件在Docker容器中启动Flume代理.
最佳答案
首先使用最近的图像(如
你可以将它的
原文链接:https://www.f2er.com/docker/436805.htmlmrwilson/docker-flume
)检查问题是否仍然存在最新的Flume代理(版本1.7).你可以将它的
docker-compose.yml
与你的产品进行比较.
像gilt/docker-flume
这样的图像较旧,仍然在1.5.