码迷,mamicode.com
首页 > 其他好文 > 详细

[elk]kafka_elk

时间:2018-06-29 00:09:08      阅读:236      评论:0      收藏:0      [点我收藏+]

标签:细节   cli   tor   tps   xmx   emd   oca   相同   tutorials   

kafka

https://www.tutorialspoint.com/apache_kafka/apache_kafka_cluster_architecture.htm
技术分享图片

https://dzone.com/articles/kafka-architecture
技术分享图片

https://leokongwq.github.io/2017/02/06/mq-kafka-tutorial.html
技术分享图片
在上图中一个topic被配置为拥有3个分区,
分区1包含两个偏移因子0和1。
分区2包含4个偏移因子0, 1, 2 和 3。
分区3包含1个偏移因子0。

分区副本的id和该副本所在的broker的id一致。

http://www.imooc.com/article/29209#
技术分享图片
由两个机器组成的集群拥有4个分区 (P0-P3) 2个consumer组. A组有两个consumerB组有4个

技术分享图片

细节注意点

/usr/local/zookeeper/bin/zkServer.sh  status

/usr/local/zookeeper/bin/zkCli.sh -server 192.168.56.11:2181
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

#/usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties & #此方式zookeeper会在shell断开后关闭

/usr/local/kafka/bin/kafka-topics.sh --create  --zookeeper 192.168.56.11:2181,192.168.56.12:2181,192.168.56.13:2181 --partitions 3 --replication-factor 3 --topic logstashtest


/usr/local/kafka/bin/kafka-topics.sh  --describe --zookeeper 192.168.56.11:2181,192.168.56.12:2181,192.168.56.13:2181  --topic logstashtest

状态说明:logstashtest有三个分区分别为1、2、3,分区0的leader是3(broker.id),分区0有三个副本,并且状态都为lsr(ln-sync,表示可以参加选举成为leader)。
[root@linux-host1 ~]# grep "^[a-Z]"   /etc/elasticsearch/elasticsearch.yml 
cluster.name: ELK-Cluster #ELK的集群名称,名称相同即属于是同一个集群
node.name: elk-node1 #本机在集群内的节点名称
path.data: /elk/data  #数据保存目录
path.logs: /elk/logs   #日志保存目
bootstrap.memory_lock: true #服务启动的时候锁定足够的内存,防止数据写入swap
network.host: 0.0.0.0 #监听IP
http.port: 9200
discovery.zen.ping.unicast.hosts: ["192.168.56.11", "192.168.56.12"]
1.3.3:修改内存限制,并同步配置文件:
[root@linux-host1 ~]# vim /usr/lib/systemd/system/elasticsearch.service #修改内存限制
LimitMEMLOCK=infinity  #去掉注释,可以最大化使用内存
[root@linux-host1 ~]# vim /etc/elasticsearch/jvm.options 
22 -Xms2g
23 -Xmx2g #最小和最大内存限制,为什么最小和最大设置一样大?
https://www.elastic.co/guide/en/elasticsearch/reference/current/heap-size.html
#官方配置文档最大建议30G以内。


curl –sXGET  http://192.168.56.11:9200/_cluster/health?pretty=true

测试获取topic:
可以在任意一台kafka服务器进行测试:
[root@linux-host3 ~]# /usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper 192.168.56.11:2181,192.168.56.12:2181,192.168.56.13:2181 --topic logstashtest

技术分享图片
状态说明:logstashtest有三个分区分别为1、2、3,分区0的leader是3(broker.id),分区0有三个副本,并且状态都为lsr(ln-sync,表示可以参加选举成为leader)。

[elk]kafka_elk

标签:细节   cli   tor   tps   xmx   emd   oca   相同   tutorials   

原文地址:https://www.cnblogs.com/iiiiher/p/9241313.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!