kafka是Apache开发的一个开源流处理平台,也目前一种比较成熟的消息系统,被广泛用作消息中间件(现如今的大数据应用中很多都是采用zookeeper+kafka集群)。
$ vim /zookeeper/conf/zoo_sample.cfg
$ vim /kafka/config/server.properties
listeners=PLAINTEXT://:9092
需要放开#port=9092
的注释,放开#host.name=localhost
的注释并改为实际kafka的ip,修改zookeeper.connect=localhost:2181
中的localhost为zookeeper实际ip。$ ./zookeeper/bin/zkServer.sh start
启动zookeeper($ ./zookeeper/bin/zkServer.sh stop
停止zookeeper),使用$ ./kafka/bin/kafka-server-start.sh ../config/server.properties
启动kafka,看到start成功提示表明kafka成功启动。$ chmod -R /zookeeper
和$ /chmod -R /kafka
对两个文件夹所有文件赋予最大权限。可以使用kafka tool软件连接zookeeper读取kafka消息,注意:如果连接zookeeper超时,看下网络是否经过vpn。kafka实战?
版权声明:本站所有资料均为网友推荐收集整理而来,仅供学习和研究交流使用。
下面的StudentService.java实现了 通过JDBC对表STUDENTS的SELECT 和INSERT操作:
工作时间:8:00-18:00
客服电话
电子邮件
admin@qq.com
扫码二维码
获取最新动态