博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
kafa单机版环境搭建
阅读量:6546 次
发布时间:2019-06-24

本文共 1008 字,大约阅读时间需要 3 分钟。

1.解压kafka压缩包(移动kafka到/usr/local/下,个人喜好):

  [root@localhost package]# tar -zxvf kafka.tar.gz

2.修改配置文件config/server.properties

  [root@localhost package]# vim /usr/local/kafka/config/server.properties

  ####broker_id####    替换kafka序号,几台机器分别就是1

  ####host_name####   替换当前机器的hostname

  ####host_name#### 替换当前机器的hostname

  ####Path####    替换kafka安装目录

  zookeeper.connect=####hosts_name####  替换zk集群名称

 

  参考如下:

  broker.id=1

  host.name=node187

  advertised.host.name=node187

  log.dirs=/home/bigdata/kafka/kafka-logs

  zookeeper.connect=node187:2181,node188:2181,node189:2181

3.启动kafka(先要确保zookeeper已启动,然后在Kafka目录执行)

  nohup bin/kafka-server-start.sh config/server.properties

  如果无报错则说明启动成功。nohup &是实现在后台启动。

4.查看进程

  jps

  

5.简单测试

  打开2个终端,分别在Kafka目录执行以下命令

  启动producer

    bin/kafka-console-producer.sh --broker-list 192.168.148.128:9092 --topic test

  启动consumer

    bin/kafka-console-consumer.sh --zookeeper 192.168.148.128:2181 --topic test --from-beginning

 

转载于:https://www.cnblogs.com/ITMan-blogs/p/9061995.html

你可能感兴趣的文章
Redis的各项功能解决了哪些问题?
查看>>
FastAdmin 极速后台管理框架 1.0.0.20190301_beta
查看>>
Selenium2 WebDriver 启动Chrome, Firefox, IE 浏览器、设置profile&加载插件
查看>>
Python标准库01 正则表达式(re包)
查看>>
Hello,Java女神
查看>>
rpc远程调用开发
查看>>
thinkphp3.2.3 引入七牛SDK
查看>>
警博士SCSDB数据库
查看>>
SCSDB数据库,大数据时代的好选择
查看>>
2018-7-17
查看>>
自动化运维之Ansible剑客参上
查看>>
docker的四种网络
查看>>
ios官方正则表达式
查看>>
Linux中详细搭建Lnmp架构(编译安装)
查看>>
-day01-服务器组成详解
查看>>
企业办公室5s标准样板
查看>>
php的引用&
查看>>
cacti+nagios之nagios的搭建(三)
查看>>
教你解决Eclipse中SVN比较乱码问题
查看>>
etcd:从应用场景到实现原理的全方位解读
查看>>