【Kafka】kafka安装使用说明

  • Z时代
  • 2024-01-10
  • 分类：综合

编程

1.介绍

kafka的工作方式和其他MQ基本相同，只是在一些名词命名上有些不同。为了更好的讨论，这里对这些名词做简单解释。通过这些解释应该可以大致了解kafka MQ的工作方式。

  • Producer （P）：就是网kafka发消息的客户端

  • Consumer （C）：从kafka取消息的客户端

  • Topic （T）：可以理解为一个队列

2.KafKa部署结构

 

 

2.安装

  2.1 下载：

         地址： 

http://kafka.apache.org/downloads.html

         选定一个版本下载，wget 

http://apache.fayea.com/kafka/0.8.2.1/kafka_2.9.1-0.8.2.1.tgz

         下载完成后解压到：tar -zxvf 

kafka_2.9.1-0.8.2.1.tgz -C /usr/local/

                                        mv kafka_2.9.1-0.8.2.1 kafka

  2.2 安装 zookeeper 

         详见： zookeeper 安装说明

2.2  配置

2.3 环境变量

             vim ~/.bash_profile

             export KAFKA_HOME=/usr/local/kafka

             export PATH=.:$JAVA_HOME/bin:$MAVEN_HOME/bin:$ANT_HOME/bin:$KAFKA_HOME/bin:$PATH

             source ~/.bash_profile

2.4  配置server.properties

               

 

操作

 

【启动zookeeper】

bin/zookeeper-server-start.sh config/zookeeper.properties &

 

【启动kafka】

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

 

【创建topic】

bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --zookeeper 127.0.0.1:2181 --topic test2

 

【生成kafka信息】

bin/kafka-console-producer.sh --broker-list 10.10.136.41:9092 --sync --topic test2

 

【消费kafka信息】

bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test2

 

【查看Topic】

bin/kafka-topics.sh --list --zookeeper localhost:2181

【查看详细信息】

bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181

以上是 【Kafka】kafka安装使用说明 的全部内容， 来源链接： utcz.com/z/517058.html

回到顶部