博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
消息队列Kafka学习记录
阅读量:6164 次
发布时间:2019-06-21

本文共 1664 字,大约阅读时间需要 5 分钟。

Kafka其实只是众多消息队列中的一种,对于Kafka的具体释义我这里就不多说了,详见:

想要下载Kafka可以直接上官网: (强烈建议一定要上官网下载,其它地方下载的可能有问题)

Kafka下载成功之后,在libs文件夹下面就是相关的jar包,如果使用Java开发就可以直接引入项目即可。同时在bin文件夹下面就是运行Kafka所需要的文件,Windows里面表示在Windows上面运行所需要的文件。相关运行的命令如下:

//跳转到指定目录,必须跳转到Kafka目录才能运行后面的命令cd C:\soft\kafka_2.10-0.8.2.2//启动zookeeperbin\windows\zookeeper-server-start.bat config\zookeeper.properties//启动server。注意和启动zookeeper的先后顺序,同时这两个启动项需要分别在dos下运行bin\windows\kafka-server-start.bat config\server.properties//创建一个主题 topicbin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test//查看所有创建的主题bin\windows\kafka-topics.bat --list --zookeeper localhost:2181//开始消费topicbin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic mytest --from-beginning//生产数据bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic mytest

这是通过服务器直接操作kafka的常用命令,而Java调用Kafka除了引用上面提到的jar包之外就是编码了,具体编码可参考:

Kafka中有很多的概念,比如groupid,partitions,topic等等。在使用之前一定要把这些概念搞清楚了才能写出可靠的代码。


 

上面都是Windows的相关命令,下面是Linux的命令

//跳转到指定目录,必须跳转到Kafka目录才能运行后面的命令cd /usr/local/kafka//启动zookeeperbin/zookeeper-server-start.sh config/zookeeper.properties//启动server。注意和启动zookeeper的先后顺序,同时这两个启动项需要分别在dos下运行(可开启两个界面)bin/kafka-server-start.sh config/server.properties//创建一个主题 topic./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test//查看所有创建的主题./bin/kafka-topics.sh --list --zookeeper localhost:2181//开始消费topicbin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning//生产数据bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

 

转载于:https://www.cnblogs.com/duanjt/p/6901997.html

你可能感兴趣的文章
多路归并排序之败者树
查看>>
java连接MySql数据库
查看>>
深入python的set和dict
查看>>
DEV实现日期时间效果
查看>>
java注解【转】
查看>>
centos 下安装g++
查看>>
下一步工作分配
查看>>
Response. AppendHeader使用大全及文件下载.net函数使用注意点(转载)
查看>>
centos64i386下apache 403没有权限访问。
查看>>
jquery用法大全
查看>>
PC-BSD 9.2 发布,基于 FreeBSD 9.2
查看>>
css斜线
查看>>
Windows phone 8 学习笔记(3) 通信
查看>>
Revit API找到风管穿过的墙(当前文档和链接文档)
查看>>
Scroll Depth – 衡量页面滚动的 Google 分析插件
查看>>
Windows 8.1 应用再出发 - 视图状态的更新
查看>>
自己制作交叉编译工具链
查看>>
Qt Style Sheet实践(四):行文本编辑框QLineEdit及自动补全
查看>>
[物理学与PDEs]第3章习题1 只有一个非零分量的磁场
查看>>
onInterceptTouchEvent和onTouchEvent调用时序
查看>>