专栏首页营琪的小记录腾讯云服务器Linux系统--安装Kafka

腾讯云服务器Linux系统--安装Kafka

个人习惯创建一个目录专门用于存放软件

创建安装目录,下载软件

我用华为的镜像,下载比较快, 并且是而二进制文件,不用编译了,解压配置后,直接使用。

[root@VM_0_16_centos /]# mkdir /usr/lib/kafka
//下载
[root@VM_0_16_centos kafka]# wget https://mirrors.huaweicloud.com/apache/kafka/2.3.1/kafka_2.12-2.3.1.tgz

解压

[root@VM_0_16_centos kafka]# tar -zxvf kafka_2.12-2.3.1.tgz 
[root@VM_0_16_centos kafka]# cd ./kafka_2.12-2.3.1/

配置属性

(设备id)broker.id=1 (日志路径)log.dirs=/tmp/kafka-logs

这两个是必须配置的,其他的根据文档自己看着办吧 。

[root@VM_0_16_centos kafka_2.12-2.3.1]# vim ./config/server.properties 

kafka一些常用配置,可以看这里https://www.jianshu.com/p/183ed5f6529b

使用kafka

  • 1.启动zookeeper, 安装包自带的,可以单节点启动(相当一个数据库)。

//jps--跟ps命令类似,打印Java进程 ,QuorumPeerMain 为zookeeper进程,说明启动成功

[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
//jps--跟ps命令类似,打印Java进程 ,QuorumPeerMain 为zookeeper进程,说明启动成功
[root@VM_0_16_centos kafka_2.12-2.3.1]# jps
3315 Bootstrap
28120 QuorumPeerMain
28473 Jps
  • 2.启动kafka-service ,会自动连接zookeeper。
[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/kafka-server-start.sh config/server.properties
  • 3.提示启动成功
  • 4.创建topic ,(队列名称)
[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic csdn_test
WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic csdn_test.

显示topic列表

[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/kafka-topics.sh --list --zookeeper localhost:2181

csdn_test
  • 5.启动Producer (相当生产者)
[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic csdn_test
>
>
  • 6.另开页面,启动Consumer(相当消费者)
[root@VM_0_16_centos kafka_2.12-2.3.1]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic csdn_test --from-beginning
  • 7.测试是否正常

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • kafka公网连接的一些记录

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 ...

    营琪
  • 格力与奥克斯空调在京东的选购指数(java爬虫案例-闲扯)

    这前段时间有一件“格力举报奥克斯空调质量"的事情,当时看一下京东这两家店铺,感觉很有意思,看着就觉得奥克斯空调选购指

    营琪
  • 腾讯云服务器Linux系统--安装python3.7.6

    window版的安装比较简单,注意安装界面把 add path 这个选项勾上,一路确定就可以了。这里主要将Linux安装python3,pip。

    营琪
  • K8S环境快速部署Kafka(K8S外部可访问)

    本次实战涉及到的K8S、Helm、NFS、StorageClass等前置条件,它们的安装和使用请参考:

    程序员欣宸
  • Java 最常见的 208 道面试题:第十五模块答案

    kafka 不能脱离 zookeeper 单独使用,因为 kafka 使用 zookeeper 管理和协调 kafka 的节点服务器。

    Java团长
  • Flink与Spark Streaming在与kafka结合的区别!

    本文主要是想聊聊flink与kafka结合。当然,单纯的介绍flink与kafka的结合呢,比较单调,也没有可对比性,所以的准备顺便帮大家简单回顾一下Spark...

    Spark学习技巧
  • Kafka ACL使用实战(单机版)

    自0.9.0.0.版本引入Security之后,Kafka一直在完善security的功能。当前Kafka security主要包含3大功能:认证(authen...

    py3study
  • Kafka 集群配置SASL+ACL

    在Kafka0.9版本之前,Kafka集群时没有安全机制的。Kafka Client应用可以通过连接Zookeeper地址,例如zk1:2181:zk2:218...

    py3study
  • Kafka常用命令收录

    本文内容主要来自两个方面:一是网上的分享,二是自研的随手记。日记月累,收录kafka各种命令,会持续更新。

    一见
  • CDH集成Kafka

    1.离线 先下载相应版本的kafka http://archive.cloudera.com/kafka/parcels/ 然后放置相应目录,如下图...

    shengjk1

扫码关注云+社区

领取腾讯云代金券