湖仓一体电商项目（十九）：业务实现之编写写入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 分布式（不是单机）的情
【Kafka】八股文梳理
可以通过实现 org.apache.kafka.clients.consumer.internals.PartitionAssignor 接口来实现。
Kafka快速入门
集群规划、集群部署、kafka群起脚本、主题命令、生产者命令、消费者命令
关于zookeeper和kafka不得不说的秘密
关于zookeeper和kafka之间有什么关系，还是有什么不得说的秘密？简介无力，详情请看正文。
kafka ui
kafka ui，一款kakfa的web管理工具,支持多集群管理。以下是各种kafka管理工具的对比。
Docker安装Kafka教程（超详细）
超详细的Docker安装Kafka教程
【Kafka从成神到升仙系列 四】你真的了解 Kafka 的缓存池机制嘛
本章我们讲述了Kafka生产端为了避免频繁的GC，创建了缓存池的机制当生产端申请的内存为16KB时，从缓存池中取缓存使用，非16KB则取不可复用的ByteBuffer使用我们在生产中要尽量避免不可复用的ByteBuffer的产生，根据当前的业务去调整batch.size的大小，否则容易造成频繁的GC
图解KafkaConsumer SyncGroupRequest请求流程
在上一篇文章中,我们分析了JoinGropRequest的流程,详细请看Kafka消费者JoinGroupRequest流程解析那么我们知道,在执行完了JoinGroupRequest之后, 所有的Member都对消费组协调器发起了SyncGroupRequest请求那么SyncGroup具体做了哪
【Kafka从成神到升仙系列 三】你真的了解 Kafka 的元数据嘛
大家好，我是爱敲代码的小黄，独角兽企业的Java开发工程师，Java领域新星创作者。这是我的系列专栏：Kafka 从成神到升仙。如果文章知识点有错误的地方，请指正！和大家一起学习，一起进步。如果感觉博主的文章还不错的话，请三连支持一下博主哦。
kafka使用教程、快速上手
kafka概述一.kafka概述1.1 定义1.2 消息队列1.2.1 传统消息队列的应用场景1.2.2 消息队列的两种形式1.3 Kafka 基础架构二.kafka安装部署2.1安装部署2.1.1.jar包下载!不要下载最新版，在win10下有问题，下载2.8.1如下图2.1.2.解压到指定的文件
