6 月 052017
参考url：https://www.elastic.co/guide/en/logstash/2.3/plugins-inputs-kafka.html
其实文档里面写的很清楚了设置 reset_beginning 为true 就可以重新读取队列，但是我测试下来都不行，后来发现官方文档写的很清楚：This is destructive! Must be used in conjunction with auto_offset_reset ⇒ smallest
才发现中文文档都少这个配置，我把auto_offset_reset ⇒ smallest 之后发现，果然队列全部从头开始读，如果不设的话，日志会从上次消费的读取。如果reset_beginning 设为false的话，直接只读取最近的日志。以后再找个时间测试下。