未完成5月24_中间件kafka

安装包放到/opt下 解压后

/opt/kafka

修改配置文件     vi server.properties 

broker.id=0 每一个boker都有一个唯一的id作为它们的名字。

port=9092 broker server服务端口

num.network.threads=2 broker处理消息的最大线程数，一般情况下数量为cpu核数

num.io.threads=8 处理IO的线程数

socket.send.buffer.bytes=1048576 socket SO_SNDBUFF参数

log.dirs=/tmp/kafka-logs kafka数据的存放地址，多个地址的话用逗号分割,多个目录分布在不同磁盘上可以提高读写性能

num.partitions=2 默认分区数

log.retention.hours=168 broker处理消息的最大线程数，一般情况下数量为cpu核数

zookeeper.connect=localhost:2181 zookeeper的地址和端口

zookeeper.connection.timeout.ms=1000000 zookeeper连接最大超时时间

 启动kafka

后台执行命令：nohup bin/kafka-server-start.sh config/server.properties & 

看日志：tail -f nohup.out

kafka

1、网络、磁盘io

2、buffer部分数据、定时推送

3、通过gzip方式进行压缩

未完成5月24_中间件kafka

原文：https://www.cnblogs.com/njq666/p/10917520.html