kafka配置以及安装
2017-02-23 11:44
225 查看
rm -f consumer.properties server.properties producer.properties zookeeper.properties
vi ./kafka/config/server.properties :修改broker.id=1,host.name=kafka02
scp /etc/hosts storm03:/etc/
scp /etc/profile storm03:/etc/
source /etc/profile
修改主机名
hostnamectl --static set-hostname kafka01
创建目录
mkdir -p /export/data/kafka/logs
先开启zookeeper
启动
bin/kafka-server-start.sh config/server.properties
查看所有topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
创建topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic freered
删除topic(需要server.properties中设置delete.topic.enable=true,否则只是声明删除或者直接重启)
bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic freered
通过shell发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic freered
用localhost会出错
bin/kafka-console-producer.sh --broker-list kafka01:9092 --topic freered
消费消息
kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic freered
查看消费位置
kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group xxx
查看某个topic详情
kafka-topics.sh --topic freered --describe --zookeeper zk01:2181
vi ./kafka/config/server.properties :修改broker.id=1,host.name=kafka02
scp /etc/hosts storm03:/etc/
scp /etc/profile storm03:/etc/
source /etc/profile
修改主机名
hostnamectl --static set-hostname kafka01
创建目录
mkdir -p /export/data/kafka/logs
先开启zookeeper
启动
bin/kafka-server-start.sh config/server.properties
查看所有topic
bin/kafka-topics.sh --list --zookeeper zk01:2181
创建topic
bin/kafka-topics.sh --create --zookeeper zk01:2181 --replication-factor 1 --partitions 1 --topic freered
删除topic(需要server.properties中设置delete.topic.enable=true,否则只是声明删除或者直接重启)
bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic freered
通过shell发送消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic freered
用localhost会出错
bin/kafka-console-producer.sh --broker-list kafka01:9092 --topic freered
消费消息
kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic freered
查看消费位置
kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group xxx
查看某个topic详情
kafka-topics.sh --topic freered --describe --zookeeper zk01:2181
相关文章推荐
- kafka安装以及配置
- Kafka的安装和使用以及配置文件的说明
- kafka安装配置(集群)以及收发消息讲解
- zookeeper、kafka的安装与配置以及集群
- 【kafka】kafka安装配置以及遇到的问题
- PHP5环境非安装配置 以及 EClipse单步调试配置 的方法 100%成功
- DELPHI下自定义包的作用,开发以及包文件的安装配置位置
- Ubuntu8.04安装、配置、无限驱动设置、网络设置、QQ以及输入法全方位服务!
- Linux下resin的安装以及配置:
- [PHP]APACHE模块化安装PHP以及MySQL 配置@Windows(PHP5)
- 【原】Boost下载安装编译配置使用指南(含Windows、Linux以及ARM Linux)
- 四种AD安装的情况以及配置方法(转帖)
- DB2安装以及在Myeclipse中配置DB2
- 如何安装EVC以及如何配置EVC(含EVC序列号)
- OCS2007R2部署之六管理工具的安装以及服务器配置
- freebsd安装以及配置pkg_add
- cloudscape网络配置,roller服务器安装,以及一些我喜欢犯的小错误
- RequisitePro7安装以及数据库的配置和RequisiteWeb的配置
- linux下weblogic的安装以及基本配置
- 安装后的配置准则以及其他准则