Linux下查看某个进程文件的启动位置找到进程ID，进入【/proc/进程ID】，并通过 ls -al查看：[mubai@localhost test]$ ps -ef | grep zookeeper... #得到进程号[mubai@localhost test]$ ll /proc/21586total 0dr-xr-xr-x2 root root 0 Dec4 14:07...

今天Kafka出现了一个问题，测试多线程高速生产数据，造成磁盘占满了。我们的kafka配置文件策略如下：log.retention.bytes=1073741842# topic每个分区的文件存储大小 1Glog.segment.bytes=536870921# topic每个分区的每个段的文件存储大小 512Mlog.retention.check.interval.ms=60000#检测时间6

一、 listeners 和 advertised.listeners在公司内网部署 kafka 集群只需要用到 listeners，内外网需要作区分时才需要用到advertised.listeners。listeners: 学名叫监听器，其实就是告诉外部连接者要通过什么协议访问指定主机名和端口开放的 Kafka 服务。我们要监听的uri的逗号分隔列表和监听器名称。指定hostname为0.0.0

一、索引（新建）文档通过使用 index API ，文档可以被 索引 —— 存储和使文档可被搜索。 但是首先，我们要确定文档的位置。正如我们刚刚讨论的，一个文档的 _index 、 _type 和 _id 唯一标识一个文档。我们可以提供自定义的 _id 值，或者让 index API 自动生成。1.1、自定义_id#语法：PUT /{index}/{type}/{id}{"fie...

一、引言与 mget 可以使我们一次取回多个文档同样的方式， bulk API 允许在单个步骤中进行多次 create 、 index 、 update 或 delete 请求。 如果你需要索引一个数据流比如日志事件，它可以排队和索引数百或数千批次。在单个API调用中执行多个批量操作。 这样可以减少开销，并可以大大提高索引速度。二、bulk API2.1、语法POST _bulk{ "...