linux下kafka从安装到使用 简单篇_akka哪个版本依赖1.8jdk

进入kafka官网  下载kafka 这里下载Scala  不要下载源码

https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.7.0/kafka_2.12-2.7.0.tgz

选择了最新2.7.0版本，下载好以后传到linux中

2.7.0依赖jdk1.8版本如果版本过低，要卸载掉系统中的java版本重新安装jdk1.8或以上版本。

将上传的kafka包解压到当前文件夹

tar zxvf kafka_2.12-2.7.0.tgz 

cd kafka_2.12-2.7.0
ll

进入解压后的文件夹，目录结构是这样的

kafka依赖zookeeper 如果linux下已经启动了zookeeper 或者使用其他服务器的zookeeper 需要修改config/server.properties 文件中的zookeeper.connect项，替换为相应的zookeeper地址和端口

vim config/server.properties

没有zookeeper 的也可以使用kafka中自带的zookeeper 

在kafka目录下启动 

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

启动时可能出现java版本低错误，更改为更高的jdk版本即可

启动成功后放着不动换一个窗口启动kafka

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

这里如果没有配置服务器名称的话，有可能会出现UnknownHostException: XXX: 未知的名称或服务 异常

解决方法

    在"/etc/hosts"中增加"127.0.0.1   XXXX"未知域名的配置，具体如下所示

[root@centos6 kafka_2.11-0.9.0.1]# vim  /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
127.0.0.1   XXX

再次启动问题即可解决

启动成功以后打开一个新窗口，创建一个topic

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

创建成功后先连接一个生产者

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

接着连接一个消费者

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test
 

在生产者中发送消息，消费者可以接受到相应的消息，表示kafka已经在服务器中成功架设，可以正常使用了。

 

Kafka脚本命令
 
创建主题:bin/kafka-topics-.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
//kafka重度依赖zookeeper 它的很多信息都保存在zookeeper当中
 
显示已有主题列表:bin/kafka-topics-.sh -list localhost:2181
 
查看某个主题详细信息:bin/kafka-topics.sh --describe --topic test --zookeeper localhost:2181
 
开启生产者:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
 
开启消费者:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
//--from-beginning 替换为 --group testGroup 则会创建组，在同一组中有一个以上消费者时只有一个消费者消费消息
 
主体删除：bin/kafka-topics-.sh --zookeeper localhost:2181 --delete --topic test
//删除主体对于kafka来说是一件不太容易的事情

 

 

 

END