【kafka专栏】生产者数据批量发送流程源码解析
kafka生产者数据发送流程源码解析
编码技巧——@KafkaListener的使用
最近在接手某个项目代码时，发现关于Kafka的consumer相关的代码写的很乱，consumer中写了大量的配置的代码，并且手动的拉取消息，并开启线程消费，不够优雅；理想的做法是单独维护kafka的consumer配置，在定义consumer的bean时，指定topic和group，仅实现消费逻辑
Springboot中使用kafka
首先说明，本人之前没用过zookeeper、kafka等，尚硅谷十几个小时的教程实在没有耐心看，现在我也不知道分区、副本之类的概念。用kafka只是听说他比RabbitMQ快，我也是昨天晚上刚使用，下文中若有讲错的地方或者我的理解与它的本质有偏差的地方请包涵。此文背景的环境是windows，linu
springBoot集成Kafka
spring boot集成Kafka
【kafka专栏】不用zookeeper怎么安装kafka集群-最新kafka3.0版本
在kafka3.0中已经可以将zookeeper去掉，kafka集群不再必须依赖zookeeper，这为运维强度的下降提供了非常多的帮助。本文为大家介绍kafka3.0，不用zookeeper如何进行集群的安装。
【kafka专栏】生产者同步及异步发送数据三种方式
apache kafka生产者客户端三种同步及异步发送数据的方式
kafka安装部署
一、安装kafka下载kafka两种方式（1）、手动下载 下载地址：Apache Kafka（2）、也可以用命令下载（直接下载到服务器哦！）：将安装包下载到/opt/monitor/kafka文件夹下面下载命令： wget http://mirrors.hust.edu.cn/apache/k
湖仓一体电商项目（八）：业务实现之编写写入ODS层业务代码
以上两个方面中第一个方面需要再Hive中预先创建对应的Iceberg表，才能写入，第二个方面不好分辨topic“KAFKA-DB-BUSSINESS-DATA”中哪些binlog数据是事实数据哪些binlog是维度数据，所以这里我们在mysql 配置表“lakehousedb.dim_tbl_con
通过java方式使用Kafka
基于Java API方式使用Kafka
湖仓一体电商项目（十九）：业务实现之编写写入DWS层业务代码
DWS层主要是存放大宽表数据，此业务中主要是针对Kafka topic “KAFKA-DWD-BROWSE-LOG-TOPIC”中用户浏览商品日志数据关联HBase中“ODS_PRODUCT_CATEGORY”商品分类表与“ODS_PRODUCT_INFO”商品表维度数据获取浏览商品主题大宽表。以上
微服务同时接入多个Kafka
最近在做微服务的迁移改造工作，其中有一个服务需要订阅多个Kafka，如果使用spring kafka自动配置的话只能配置一个Kafka，不符合需求，该文总结了如何配置多个Kafka，希望对您有帮助。
windows 安装kafka流程
windows 安装kafka流程
Kafka锦集（二）：三种不同方式，查看kafka是否已启动
本文详细阐述了以三种不同的方式查看kafka服务是否正常启动，它们分别是：1）jps -ml；2）lsof -i:9092；3）netstat -nalpt | grep 9092；
【Kafka从成神到升仙系列 六】kafka 不能失去网络通信，就像西方不能失去耶路撒冷
这一篇文章主要从 Kafka 服务端的网络架构入手，剖析了服务端网络如何连接、如何处理、如何返回的。kafka 的网络架构使用了 Reactor 模型，利用 1 + N + M 的架构模式，将 kafka 的通信支撑起来，最后通过 mute 的方法保障了分区有序性。我是爱敲代码的小黄，独角兽企业的J
kafka官方文档中文翻译（kafka参数解释）
我们认为流媒体平台具有三个关键功能：Kafka有什么优点？它用于两大类应用程序：要了解Kafka如何做这些事情，让我们从下而上地研究和探索Kafka的功能。首先几个概念：Kafka有四个核心API：在kafka客户端和服务器之间的通信以简单的，高性能的，语言无关完成TCP协议。此协议版本化，并保持与
Kafka ui 搭建以及使用
kafka 本身没有自带相关的 ui 界面，但是很多时候没有页面意味着只有使用命令行进行相关操作如创建 topic、更改 topic 信息、重置 offset 等等。但实际使用中这种效果很差劲，我们一般还是会借助其他软件，实现对 kafka 的页面管控。结合这张图与实际体验，推荐大家使用 ui fo
RocketMQ 介绍及基本概念
1 介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。1.1 RocketMQ 特点支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型在一个队列中可靠的先进先出（FIFO）和严格的顺序传递 （RocketMQ可以
图解KafkaConsumer SyncGroupRequest请求流程
在上一篇文章中,我们分析了JoinGropRequest的流程,详细请看Kafka消费者JoinGroupRequest流程解析那么我们知道,在执行完了JoinGroupRequest之后, 所有的Member都对消费组协调器发起了SyncGroupRequest请求那么SyncGroup具体做了哪
仿牛客社区项目（第五章）（上）
在C盘下找到wbem文件夹，且里面包含WMIC.exe，将其添加到系统变量path中去。比如在生产者的命令行中继续输入信息，很快在消费者这边也能得到消息。当遇到“‘wmic’不是内部或外部命令，也不是可运行程序”。，在系统变量path中新建该路径。就可以正常启动Kafka了。可以看到生产者发送的消息
20道常见的kafka面试题以及答案
1、kafka的消费者是pull(拉)还是push(推)模式，这种模式有什么好处？2、kafka维护消息状态的跟踪方法3、zookeeper对于kafka的作用是什么?4、kafka判断一个节点还活着的有那两个条件？5、讲一讲 kafka 的 ack 的三种机制6、kafka 分布式（不是单机）的情
