kafka中文教程 学习记录

首先准备好linux机器环境,参考此篇文章:快速搭建Linux服务器环境

单机版

1. 下载代码

https://kafka.apache.org/downloads.html

官方的下载链接比较慢,这里可以使用第三方下载转发的链接地址:

wget --no-check-certificate https://dl0.serctl.com/downloads8/2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ ll
total 84372
-rw-rw-r--. 1 vagrant vagrant 86396520 Sep 20 08:46 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz$ tar -xzf 2021-11-05-12-14-20--kafka_2.13-3.0.0.tgz
$ cd kafka_2.13-3.0.0/

2. 启动服务

启动kafka 需要jdk环境,可参考这篇文章:在linux上面安装jdk

kafka自带打包和配置好的Zookeeper

启动Apache Kafka 内置的zookeeper

$ cd kafka_2.13-3.0.0/
$ bin/zookeeper-server-start.sh config/zookeeper.properties

启动kafka服务

$ cd kafka_2.13-3.0.0/
$ bin/kafka-server-start.sh config/server.properties

3. 创建一个主题(topic)

创建一个名为“test”的Topic,只有一个分区和一个备份

$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

查看已创建的topic信息:

$ cd kafka_2.13-3.0.0/
$ bin/kafka-topics.sh --describe --topic test --bootstrap-server localhost:9092
Topic: test     TopicId: DdW4QskuTH2DwnGvM0Mjdg PartitionCount: 1       ReplicationFactor: 1    Configs: segment.bytes=1073741824Topic: test     Partition: 0    Leader: 0       Replicas: 0     Isr: 0

4. 发送消息

生产者

$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message

5. 消费消息

$ cd kafka_2.13-3.0.0/
$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning


上面我们使用命令的方式简单演示了一下kafka的基本流程。

你有哪些疑问吗?

kafka 安装和启动相关推荐

  1. Linux Kafka安装与启动

    1. kafka安装与配置 官网下载安装解压缩:http://kafka.apache.org/downloads 下载解压启动 启动命令:bin/kafka-server-start.sh -dae ...

  2. kafka 启动_Kafka的安装与启动

    安装 在mac上可以使用brew install kafka进行kafka的安装,在安装kafka时,会自动检测有无zookpeer,如果没有的话也会安装一个. 启动kafka 启动kafka,首先要 ...

  3. Apache Kafka(二)- Kakfa 安装与启动

    安装并启动Kafka 1.下载最新版Kafka(当前为kafka_2.12-2.3.0)并解压: > wget http://mirror.bit.edu.cn/apache/kafka/2.3 ...

  4. 【kafka可视化工具】kafka-eagle在windows环境的下载、安装、启动与访问

    本文目录 一.Kafka eagle的下载 步骤一:访问官方网站:Download - EFAK 步骤二:点击 Direct File Download 二.kafka-eagle的安装 步骤一:解压 ...

  5. Kafka详解(上)——消息系统分类、Kafka安装、两种启动、基本概念、两种架构、核心配置文件

    1 消息和消息系统 ​ 消息(Message)是指在应用间传送的数据.消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象. 1-1 消息系统是什么 ​ 消息系统负责将数据从一个应用 ...

  6. Kafka基本安装和启动

    Kafka基本安装和启动 一.下载解压Kafka 二.启动zookeeper 三.启动Kafka 四.创建测试Topic 五.启动Producer 六.启动Consumer 七.Producer窗口发 ...

  7. Kafka 安装及快速入门

    转载请注明原创地址为:http://www.54tianzhisheng.cn/2018/01/04/Kafka/ 介绍 官网:http://kafka.apache.org/ Apache Kafk ...

  8. Kafka 安装配置及快速入门

    2019独角兽企业重金招聘Python工程师标准>>> 一.简介 官网:http://kafka.apache.org/ Apache Kafka是分布式发布-订阅消息系统.它最初由 ...

  9. 学习笔记Kafka(四)—— Kafka安装配置(3)—— Kafka多代理配置及常用操作

    一.环境准备 Centos7, 1 CPU , 2G Memory ,20G Disk , Virtual System Hosts : node110, node111 , node112 全部配置 ...

最新文章

  1. WPF中的容器控件——Grid
  2. 面试官:支撑日活百万用户的高并发系统,应该如何设计其数据库架构?
  3. java基本语法借阅_课内资源 - 基于Java和MySql实现的光盘借阅管理系统
  4. 自学python有用吗-普通人学Python有用吗?学完能做什么?
  5. SAP云平台和SAP C4C之间的OAuth2.0配置
  6. LeetCode 822. 翻转卡片游戏(哈希)
  7. 随机森林降维matlab代码,随机森林代码实现问题
  8. 11、进入保护模式-V
  9. js代码 设为首页 加入收藏
  10. 页面显示正常,控制台报错
  11. 2021年大学计算机基础,2021年大学计算机基础试题题库及答案-20210418080659.doc-原创力文档...
  12. 微信公众号发送模板消息
  13. p2p借贷项目面试题
  14. Java 定义一个 Employee类,定义方法输出Employee的名字,年龄,总收入。编写应用程序使用Employee
  15. html 公告栏 上下滚动,jQuery实现上下滚动公告栏详细实例
  16. 有意思的网站 - 收集
  17. 笑对过往、活在当下、期盼未来
  18. Vue开发版本与生产版本的区别
  19. Latex使用技巧:插入动态图
  20. stm32F103中文参考手册

热门文章

  1. Roguelike大全,part 3
  2. springboot使用kafka发送消息,消息过大报错
  3. WPF教程三:布局之WrapPanel面板
  4. Lesson 47 A cup of coffee 一杯咖啡
  5. php项目css加载失败,CSS页面加载失败的原因有哪些
  6. JDBC浅尝辄止——JAVA如何使用最朴素的方法连通数据库
  7. java制作月度报表_Java报表制作详细过程
  8. 【C++】基于Easyx的UI库(2022-8-21 V1)
  9. 如何利用高德地图URI加载区域边界
  10. 硬盘计算机类比推理,广西公务员考试类比推理每日练习(2016.11.23)