SUSE Linux Enterprise Server 11 SP3下Kafka服务安装
kafka是一款分布式消息发布和订阅的系统,具有高性能和高吞吐率。 更多说明请自行了解,直接进入主题。
kakfa 安装之前需要安装jdk,不做更多说明
一、下载kafka
进入下载页面:http://kafka.apache.org/downloads.html
解压
1 tar -xzf kafka_2.10-0.10.1.0.tgz 2 cd kafka_2.10-0.10.1.0
/bin 启动和停止命令等。
/config 配置文件
/libs 类库
二、启动服务
运行kafka需要使用Zookeeper,所以你需要先启动Zookeeper,如果你没有Zookeeper,你可以使用kafka自带打包和配置好的Zookeeper。
bin/zookeeper-server-start.sh config/zookeeper.properties &
在启动kafka服务
bin/kafka-server-start.sh config/server.properties &
三、创建一个主题(topic)
创建一个名为“test”的Topic,只有一个分区和一个备份:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
创建好之后,可以通过运行以下命令,查看已创建的topic信息:
bin/kafka-topics.sh --list --zookeeper localhost:2181 test
四、发送消息
Kafka提供了一个命令行的工具,可以从输入文件或者命令行中读取消息并发送给Kafka集群。每一行是一条消息。
运行producer(生产者),然后在控制台输入几条消息到服务器。
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test This is a message This is another message
五、消费消息
Kafka也提供了一个消费消息的命令行工具,将存储的信息输出出来。
1 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 2 This is a message 3 This is another message
这里只是单机测试。
下面关于Kafka的文章您也可能喜欢,不妨参考下:
Kafka 的详细介绍:请点这里
Kafka 的下载地址:请点这里
相关推荐
Kafka 2020-09-18
guicaizhou 2020-09-15
jiangkai00 2020-07-18
CobingLiu 2020-06-16
yangyutong00 2020-06-12
sweetgirl0 2020-06-09
guicaizhou 2020-06-12
yanghuashuiyue 2020-11-14
huangwei00 2020-10-14
hannuotayouxi 2020-08-20
guicaizhou 2020-08-01
sweetgirl0 2020-07-27
liuxingen 2020-11-13
wangying 2020-11-13
王谦 2020-11-03
shenzhenzsw 2020-10-09
guicaizhou 2020-09-30
jiaomrswang 2020-09-23
jyj0 2020-09-21