Kafka之——安装并(单节点)配置启动Kafka
2017-10-26 00:07
543 查看
转载请注明出处:http://blog.csdn.net/l1028386804/article/details/78348367
1. 下载Kafka
从Kafka官网下载最新的Kafka,目前我下载的版本为kafka_2.10-0.8.1.1.tgz
后台启动Zookeeper
./zookeeper-server-start.sh -daemon /usr/local/kafka_2.10-0.8.1.1/config/zookeeper.properties
后台启动Kafka
./kafka-server-start.sh -daemon /usr/local/kafka_2.10-0.8.1.1/config/server.properties
1. 下载Kafka
从Kafka官网下载最新的Kafka,目前我下载的版本为kafka_2.10-0.8.1.1.tgz2、解压Kafka
tar -zxvf kafka_2.10-0.8.1.1.tgz
3. 修改Zookeeper服务器配置,并启动
cd kafka_2.10-0.8.1.1 vi config/zookeeper.properties #修改ZooKeeper的数据目录 dataDir=/usr/local/db/zookeeper #配置host.name和advertised.host.name为IP地址,防止通过Java客户端连接时解析为localhost host.name=192.168.209.121 advertised.host.name=192.168.209.121 #启动Zookeeper服务器 ./zookeeper-server-start.sh /usr/local/kafka_2.10-0.8.1.1/config/zookeeper.properties
后台启动Zookeeper
./zookeeper-server-start.sh -daemon /usr/local/kafka_2.10-0.8.1.1/config/zookeeper.properties
4.修改Kafka配置,并启动Kafka服务器
vi config/server.properties log.dirs=/usr/local/kafka/kafka-logs #启动Kafka服务器 ./kafka-server-start.sh /usr/local/kafka_2.10-0.8.1.1/config/server.properties
后台启动Kafka
./kafka-server-start.sh -daemon /usr/local/kafka_2.10-0.8.1.1/config/server.properties
5.创建并查看Topic
cd /usr/local/kafka_2.10-0.8.1.1/bin/ ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test Created topic "test". #查看刚才的topic ./kafka-topics.sh --list --zookeeper localhost:2181 test
6. 使用生产者发送消息,每行是一条独立的消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test This is a message This is My mesage
7. 使用消费者接收消息
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning This is a message This is My me
相关文章推荐
- Linux下安装并(单节点)配置启动Kafka
- kafka_2.10-0.8.1.1.tgz的1或3节点集群的下载、安装和配置(图文详细教程)绝对干货
- kafka_2.10-0.8.1.1.tgz的1或3节点集群的下载、安装和配置(图文详细教程)绝对干货
- linux下单节点Kafka安装配置流程
- mysql免安装配置教程及遇到1067服务启动不成功的问题解决方法
- MySQL简单入门——安装配置启动登录
- Linux下安装、配置、启动Apache
- 解决“由于应用程序的配置不正确,应用程序未能启动,重新安装应用程序可能会纠正这个问题”
- Linux基本操作系列(二):在CentOS 6.8系统上安装Tomcat并配置自动启动
- Resin安装,配置和在Linux上的自动启动问题
- CentOS6.2下一步一步源代码安装OpenStack(九)Swift存储节点安装、配置及运行
- memcached的基本命令(安装、卸载、启动、配置相关)
- Linux下Mongodb安装和启动配置.txt .
- MySQL5.5.23数据库免安装版本在Windows系统上配置启动
- mac上安装配置启动nginx,实现反向代理
- 安装Apache+php,配置正确,而启动不了Apache
- CentOS6.2下一步一步源代码安装OpenStack(八)Swift代理节点配置、运行
- Mac 安装配置启动Tomcat
- nginx 安装、编写启动脚本、配置
- ZooKeeper配置引起Hbase和Kafka启动异常