iguidao

childe，你好： 我说明以下三点： 1、如你所说，我做了个测试，重启hangout的时候，确实kafka会有rebalance group topic-test的日志信息出现，但是我昨天一直到今天并没有停止hangout，并且kafka日志也没有rebalance group topic-test的信息，最后查Elasticsearch日志数据量还是比file文件中日志数据量多（查询的是一小时的数据）。 2、为了多方面测试，我昨天用logstash2.3.4版本也消费kafka数据写入Elasticsearch，用的是同一组kafka，不同的topic，发现最后Elasticsearch和file文件中一小时的数据是一样的，并没有出现Elasticsearch多数据的情况。 3、我想到了一个问题：有没有可能是hangout消费完kafka数据并写入Elasticsearch之后成功之后返回给kafka的时候出现错误，然后并没有返回给kafka这条日志已经消费，所以再次消费了同一条数据？请问如果hangout写入Elasticsearch之后成功之后，返回给kafka的那段代码是怎么写的？有没有可能写入Elasticsearch成功因为某方面原因返回给kafka的结果是消费失败？

补充：我也重启过logstash，也么有出现多数据的情况