如何在linux中找到kafka版本？是否有办法找到已安装的kafka版本,而不是在下载时提及版本？
我需要从性能和查询方面的细节,我从一些网站上了解到,在使用columnfamily时只能给出一个密钥,如果是这样你会给我的密钥空间建议什么,我需要使用group by,order by,count,sum ,ifnull,concat,join,有时是嵌套查询.
我需要在其中一个索引中进行聚合+排序+分页.
我了解了弹性搜索的内部功能,
我有5个总分片,它将对各个分片进行排序并获取结果,默认情况下,每个分片将返回10个记录.然后再对50条记录进行排序,它将获取前10条记录,因为默认大小为10.
输出继电器:
聚合结果在名为"aggregations"的单独字段中返回.为了在此聚合数据中进行分页,大小和from不起作用.
厌倦了做termBuilder.size(500),现在根据这个链接的逻辑是不同的(http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/search-aggregations-bucket-terms-aggregation .html)
这会导致数据不准确.
任何人都可以建议我如何处理聚合+分页.
我需要从服务器获取一个密钥空间作为转储并将转储恢复到我的本地cassandra,我知道在mysql中做但在nosql中怎么做？我从网站上了解到nodetool,snapshot和csv文件格式可以实现这一点,但我无法得到它？
我是Elastic Search的新手,
在版本上进行研发是:1.2.2和1.3.2
两者都为我的数百万条记录产生了相同的结果.
我的问题是我在查询中进行术语聚合以产生结果.在我的要求中,我需要将记录从0到10和10到11分页.
有什么建议吗？我怎样才能做到这一点.
而且我也无法找到1.2.2和1.3.2版本之间的区别,任何引用文档都会更有帮助.
我使用的是kafka-0.8.1.1版本,在这个版本中,自动重新连接不能通过java代码工作.我有属性文件
props.put("zookeeper.connect", "zoo1:2181,zoo2:2181");
props.put("group.id", KAFKA_GROUPID);
props.put("zookeeper.session.timeout.ms", "10000");
props.put("zookeeper.sync.time.ms", "200");
props.put("auto.commit.interval.ms", "1000");
当我启动消费者线程时,它连接到kafka服务器,在线程运行服务器之间丢失与kafka服务器的连接2小时.如果它重新连接kafka消费者没有收到任何消息,它也不会抛出任何错误流.
我们如何检测它丢失连接并自动重新连接消费者线程.
提前致谢