kafka集群安装配置

Posted 王振龙

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka集群安装配置相关的知识,希望对你有一定的参考价值。

1.下载安装包

2.解压安装包

3.进入到kafka的config目录修改server.properties文件

 

进入后显示如下:

 

修改log.dirs,基本上大部分都是默认配置

 

 kafka依赖zookeeper保存一些meta信息,所以这些需要配置

分发安装包到其他节点上

scp -r ....

再次修改配置文件(重要)

依次修改各服务器上配置文件的的broker.id,分别是0,1,2不得重复。

启动集群

依次在各节点上启动kafka

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

 执行命令的情况如下:

 

 

5.4Kafka常用操作命令

查看当前服务器中的所有topic

bin/kafka-topcs.sh --list --zookeeper  zk01:2181

 

 

 

创建topic

./kafka-topics.sh --create --zookeeper mini1:2181 --replication-factor 1 --partitions 3 --topic first

删除topic

sh bin/kafka-topics.sh --delete --zookeeper zk01:2181 --topic test

需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

通过shell命令发送消息

kafka-console-producer.sh --broker-list kafka01:9092 --topic first1

通过shell消费消息

sh bin/kafka-console-consumer.sh --zookeeper zk01:2181 --from-beginning --topic test1

l 查看消费位置

sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper zk01:2181 --group testGroup

查看某个Topic的详情

sh kafka-topics.sh --topic test --describe --zookeeper zk01:2181

以上是关于kafka集群安装配置的主要内容,如果未能解决你的问题,请参考以下文章

KafKa集群安装配置

KafKa集群安装配置

大数据高可用集群环境安装与配置(10)——安装Kafka高可用集群

Kafka集群安装和配置

Kafka集群安装和配置

Kafka安装和集群的相关配置