1. 什么是Apache Kafka? 答:Apache Kafka是一个发布 - 订阅开源消息代理应用程序。这个...[作者空间]
Kafka 工作流程分析 1、Kafka生产过程分析 (1)写入方式 producer采用推(push)模式将消息...[作者空间]
相对于Kafka的生产者API,消费者的API略显繁杂,本文总结了0.11.0版本的kafka消费者的几种消费模式...[作者空间]
利用PlantUML可以非常方便的画各种UML图,下面是我画的KafkaProducer的类图。 最方便的是这个图...[作者空间]
流程 流程讲解 在我们通过代码send消息之后,这条消息就会发往拦截器Interceptor Intercepto...[作者空间]
记录常用的kafka常用的topic相关命令 查看topic列表 创建topic --create:创建命令;--...[作者空间]
在一个Kafka集群中如何选择topics/partitions的数量 翻译自How to choose the ...[作者空间]
前情提要 现如今,消息中间件已经在很多公司的业务中被广泛使用:业务解耦,消峰填谷,对接大数据,流式计...[作者空间]
使用flink FlinkKafkaProducer 往kafka写入数据的时候要求使用EXACTLY_ONCE语...[作者空间]
本节重点讨论 Kafka 的消息拉起流程。 @TOC 1、KafkaConsumer poll 详解 消息拉起主要...[作者空间]
温馨提示:整个 Kafka 专栏基于 kafka-2.2.1 版本。 1、KafkaConsumer 概述 根据 ...[作者空间]
温馨提示:本文基于 Kafka 2.2.1 版本。 上文 《源码分析 Kafka 消息发送流程》 已经详细介绍了 ...[作者空间]
温馨提示:整个 Kafka Client 专栏基于 kafka-2.3.0 版本。 @TOC 1、KafkaPro...[作者空间]
本文根据Apache Flink 实战&进阶篇系列直播课程整理而成,由哈啰出行大数据实时平台资深开发刘博分享。通过...[作者空间]
目录 一、系统相关指标 1.系统信息收集java.lang:type=OperatingSystem 2.Thre...[作者空间]
本篇以Kafka0.10.1.1版本以基础,对Kafka的基本组件的实现细节及其基本应用进行了详细介绍,同时,通过...[作者空间]
学习来源: 《大数据技术学习之Kafka基本原理》 《kafka官网》 1.简介 Apache Kafka由著名职...[作者空间]
前言 异地灾备可以防止一个机房出现灾难而导致整个系统无法提供服务的问题。异地双活在异地灾备的基础上减少了数据的冗余...[作者空间]
Kafka 101系列文章第2篇:Kafka安装使用。 安装Java Kafka是用Java和Scala写的,Ka...[作者空间]
背景 我们的Kafka一直是没有安全机制地裸奔,最近需要给它升个级,加上认证和授权机制,认证机制是SASL/PLA...[作者空间]