我在向flume头添加时间戳时遇到问题。这是从我的conf文件中截取的。
agent.sources.avrosource.interceptors.addTimestamp.type = org.apache.flume.interceptor.TimestampInterceptor$Builder当我使用maven进行调试时，我看到时间戳没有添加到头中。以下是调试输出：
2013-12-05 10:56:34,963 (SinkRunner-PollingRunner-DefaultSinkProcessor) [DEBUG - com.btoddb.flume.sinks.cassandra.CassandraSink.process(CassandraSink.java:135)] event: [Event headers = {key=value}, body.length = 12 ]仅供参考，我也添加了这样的时间戳，但再次它不工作。
agent.sources.avrosource.interceptors = addTime
agent.sources.avrosource.interceptors.addTime.type = timestamp任何帮助都会得到回报。谢谢
1条答案
按热度按时间wljmcqd81#
如果你在Flume上有这个uselocaltimestamp，它必须工作。
agent.sinks.sinkdest.hdfs.uselocaltimestamp=真