我正在尝试使用flume使用twitter流api并将tweet索引到elasticsearch。我将flume.conf设置为使用com.cloudera.flume.source.twittersource作为twitter源（使用我的dev令牌），并对接收器使用默认的elastisearch。
我能够获得tweets（因为我还将其保存到hdfs中，当我打开文件时，我可以看到tweets），但是当我搜索到我的elasticsearch时，我得到的响应是：

{
      _index: twitter-2014-02-14
      _type: tweet-rt
      _id: ilL5ZrBRSlqrZcsVUbnO-g
      _version: 1
      _score: 1
      _source: {
      @message: org.elasticsearch.common.xcontent.XContentBuilder@12da4409
      @timestamp: 2014-02-14T10:16:13.000Z
      @fields: {
      timestamp: 1392372973000
      }

  }

这里是我的Flume配置的例子。

# - ElasticSearch Sink

TwitterAgent.sinks.ES.type = elasticsearch
TwitterAgent.sinks.ES.channel = FileChannel
TwitterAgent.sinks.ES.hostNames = 192.168.10.100:9300
TwitterAgent.sinks.ES.indexName = twitter
TwitterAgent.sinks.ES.indexType = tweet-rt
TwitterAgent.sinks.ES.clusterName = testou

我还需要补充什么吗？我不明白为什么es不能反序列化我的tweet。
有什么想法吗？
谢谢你