最终目标：连接elasticsearch和kafka，并接收es索引中的持续更改事件到kafka。从Kafka，我有听众做进一步的处理。
方法：我使用logstash输入和输出插件。这是配置代码。

input {
        elasticsearch {
                hosts => ["localhost:9200"]
                index => "liferay-20116"
        }
}
output {
      kafka {
        topic_id => "elastic-topic-index"
        codec => json
      }
}

这是工作，但有一个奇怪的问题。
当我听Kafka的时候，它读取了所有来自es的文档，现在大约有176个文档。
一旦它读了，它会停下来一段时间，比如说2秒钟，然后再次读取整个176个文档！
我不知道是什么问题，这是因为罗格藏行为还是Kafka行为怪异？
任何帮助都将不胜感激！