Kafka

【kafka面试题2】如何保证kafka消息的顺序性

【kafka面试题2】如何保证kafka消息的顺序性_kafka怎么保证顺序性
2023-07-08 16:14 阅读数 61

SSM 如何使用 Kafka 实现消息队列？

本文介绍了如何使用 SSM 框架和 Kafka 实现消息队列。首先介绍了 Kafka 的基本概念和组件，包括 Broker、Topic、Partition、Producer、Consumer 和 Consumer Group 等；然后介绍了 Kafka 的 Java 客户端 KafkaProd...
2023-05-26 14:37 阅读数 42

《kafka 核心技术与实战》课程笔记（三）

Kafka 简介Apache Kafka是消息引擎系统，也是一个分布式流处理平台（Distributed Streaming Platform）。Kafka 社区将其清晰地定位为一个分布式、分区化且带备份功能的提交日志（Commit Log）服务。Kafka 在设计之初就旨在提供三个方面的特性...
2023-05-24 15:10 阅读数 97

《kafka 核心技术与实战》课程笔记（四）

Kafka 线上集群部署方案操作系统Kafka 由 Scala 语言和 Java 语言编写而成，编译之后的源代码就是普通的“.class”文件。本来部署到哪个操作系统应该都是一样的，但是不同操作系统的差异还是给 Kafka 集群带来了相当大的影响。目前常见的操作系统有 3 种：Linux、Wi...
2023-05-24 15:10 阅读数 29

Kafka详解（三）客户端TCP链接管理机制

1. 生产者TCP链接管理1.1 Kafka生产者程序概览Kafka 的 Java 生产者 API 主要的对象就是 KafkaProducer。通常我们开发一个生产者的步骤有 4 步。构造生产者对象所需的参数对象。 利用第 1 步的参数对象，创建 KafkaProducer 对象实例。 使用 ...
2023-04-23 22:15 阅读数 22

Flink接收Kafka流数据使用Table API和SQL处理

Flink接收Kafka流数据使用Table API和SQL处理Apache Flink具有两个关系API - Table API和SQL - 用于统一流和批处理。 Table API是Scala和Java语言集成查询API，允许以非常直观的方式来做数据处理，此API的核心概念是 Table ...
2023-04-23 17:12 阅读数 23

RabbitMQ、RocketMQ、Kafka延迟队列实现

延迟队列在实际项目中有非常多的应用场景，最常见的比如订单未支付，超时取消订单，在创建订单的时候发送一条延迟消息，达到延迟时间之后消费者收到消息，如果订单没有支付的话，那么就取消订单。那么，今天我们需要来谈的问题就是RabbitMQ、RocketMQ、Kafka中分别是怎么实现延时队列的，以及他...
2022-12-22 09:59 阅读数 60

Kafka消息队列详解

Kafka在0.10.0.0版本以前的定位是分布式，分区化的，带备份机制的日志提交服务。而kafka在这之前也没有提供数据处理的顾服务。大家的流处理计算主要是还是依赖于Storm，Spark Streaming，Flink等流式处理框架。Storm，SparkStreaming，Flink流处...
2022-09-05 10:13 阅读数 101

java 读取kafka指定offset的内容

java 读取kafka指定offset的内容
2022-07-25 17:12 阅读数 35

带你深度剖析Kafka架构知识点

带你深度剖析Kafka架构知识点，学习了解Kafka数据处理、Kafka 核心组件、broker和集群、Consumer与topic关系、Kafka消息的分发、Consumer的负载均衡开发技术。
2022-03-24 10:48 阅读数 90
技术
今日推荐
ioDraw Mac客户端安装教程
阅读数 19
下载桌面版
GitHub
百度网盘（提取码：draw）
Gitee
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱：[email protected]
QQ群：766591547
关注微信
©2020-2024 ioDraw All rights reserved, Privacy Policy