首页 > 其他分享 >从头开始学Kafka

从头开始学Kafka

时间:2022-10-24 19:31:08浏览次数:41  
标签:从头开始 Producer Admin 偏移量 Kafka API Consumer

第一章 Kafka概述

1.1 Kafka概述之基本概念

1.2 Kafka概述之ZooKeeper

1.3 Kafka概述之环境搭建


第二章 Kafka之Admin API

2.1 Kafka Admin API之创建客户端

2.2 Kafka Admin API之创建主题

2.3 Kafka Admin API之查询主题

2.4 Kafka Admin API之删除主题

2.5 Kafka Admin API之查看主题描述信息

2.6 Kafka Admin API之查看主题配置信息

2.7 Kafka Admin API之修改主题配置信息

2.8 Kafka Admin API之增加分区


第三章 Kafka之Producer API

3.1 Kafka Producer API之异步发送

3.2 Kafka Producer API之异步阻塞发送

3.3 Kafka Producer API之异步回调发送

3.4 Kafka Producer API之发送原理

3.5 Kafka Producer API之自定义分区负载均衡

3.6 Kafka Producer API之消息传递保障


第四章 Kafka之Consumer API

4.1 Kafka Consumer API之自动提交偏移量

4.2 Kafka Consumer API之手动提交偏移量

4.3 Kafka Consumer API之单个分区提交偏移量

4.4 Kafka Consumer API之手动控制一个或多个分区的消费

4.5 Kafka Consumer API之多线程并发处理

4.6 Kafka Consumer API之控制偏移量的起始位置


第五章 Kafka之Stream API

5.1 Kafka Streams API之概述

5.2 Kafka Streams API之统计单词

5.3 Kafka Streams API之算子演示


第六章 Kafka集群

6.1 Kafka集群之基本概念

6.2 Kafka集群之Linux下单机部署

6.4 Kafka集群之副本集

6.5 Kafka集群之Leader选举


标签:从头开始,Producer,Admin,偏移量,Kafka,API,Consumer
From: https://blog.51cto.com/u_15843693/5791048

相关文章

  • 从头开始学ElasticSearch
    第一章ElasticSearch概述1.1ElasticSearch概述之基本概念1.2ElasticSearch概述之安装1.3ElasticSearch概述之Kibana安装1.4ElasticSearch概述之增删改查第二章Elastic......
  • Kafka历史&客户端功能介绍
    Producer新旧对比新版本:发送过程被分为两个线程,一条消息发送后经用户主线程进入内存缓冲区,SenderI/O线程将缓冲区中的数据分批发给Kafkabroker完全异步发送消息,通过F......
  • 4.5 Kafka Consumer API之多线程并发处理
    1.Consumer一对一消费Partition(1).简介这种类型是经典模式,每一个线程单独创建一个KafkaConsumer消费一个partition,用于保证线程安全。(2).代码示例publicclassKafkaCon......
  • 6.4 Kafka集群之副本集
    1.简介kafka的数据是存储在日志文件中的,kafka副本集(副本因子)是指将这些日志文件复制多份从而起到数据备份的目的。kafka中的topic只是个逻辑概念,实际存储数据的是partiti......
  • 6.5 Kafka集群之Leader选举
    1.Broker选举(1).不采用多数投票方式选举的原因kafka并没有采用多数投票来选举leader的(redis和es采用的是多数投票方式来进行选举的),原因有两个,一是防止选举时选举到了数......
  • Kafka Consumer指定时间戳位置消费消息
    KafkaConsumer指定时间戳位置消费消息若用户不想从最旧的或最早的offset位置开始消费,想指定某个时间戳位置开始消费,是否可行呢?答案:可行的用户给定时间戳,kafkaserve......
  • 15.Linux下安装Kafka
    1.解压解压安装包并将解压后的目录移动到/usr/local/kafka目录下。tar-zxvfkafka_2.11-2.3.0.tgzmvkafka_2.11-2.3.0/usr/local/kafkacd2.启动cd3.检验执行jps命令,如......
  • 从头开始学Linux
    1.Linux基础2.编辑器命令3.磁盘命令4.文件操作命令5.解压缩命令6.权限修改命令7.进程命令8.端口命令9.内存状态命令10.上传与下载命令11.Linux下安装Jdk12.Linux下安装Tomca......
  • 聊聊kafka
    两个月因为忙于工作毫无输出了,最近想给团队小伙伴分享下kafka的相关知识,于是就想着利用博客来做个提前的准备工作了;接下来会对kafka做一个简单的介绍,包括利用akf原则来解析......
  • kafka springBoot 报错 not present and missingTopicsFatal is true kafka missing-t
    这个问题可以追溯到springboot和kafka的版本问题,解决这个问题太麻烦,要去看官方文档,我选择不看。这里提供一种通用的解决方式在kafkaConfig配置文件中添加下面的代码/**......