|
版本:kafka_2.10-0.8.1.tgz
服务器列表:
ip | broker-id | 192.168.199.129 | 0 | 192.168.199.130 | 1 | 192.168.199.131 | 2 |
server.properties配置
配置 | 说明 | log.retention.hours=72 | 日志保存时长(小时),默认7天 | zookeeper.connect=192.168.199.129:2181,192.168.199.130:2181,192.168.199.131:2181 | zk列表 | log.dirs=/tmp/kafka-logs | 日志index,data存储位置 | port=9092 | 端口 | broker-id | id |
producer.properties配置
配置 | 说明 | metadata.broker.list=192.168.199.129:9092,192.168.199.130:9092,192.168.199.131:9092 | broker列表 | producer.type=sync |
sync同步发送数据
async异步发送数据,速度快,但可
有可能会丢失数据
|
consumer.properties配置
配置 | 说明 | zookeeper.connect=192.168.199.129:2181,192.168.199.130:2181,192.168.199.131:2181 | zk列表 |
启动:加上JXM_PORT=9999,表示可以通过9999端口,来获取kafka的jmx信息
JMX_PORT=9999 ./kafka-server-start.sh ../config/server.properties &
用jconsole监控
|
|
|