Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
大数据技术之Kafka——Kafka入门
目录 一 概述 1 1 为什么要有Kafka 1 2 定义 1 3 消息队列 1 消息队列的应用场景 2 消息队列的两种模式 1 4 基础架构 二 Producer生产者 2 1 生产者消息发送流程 2 1 1 发送原理 2 2 异步发送A
kafka
kafka
大数据
分布式
kafka踩坑——java找不到kafka-run-class.sh: line 309: exec: java: not found
今天执行 user 1 test 1 opt kafka sudo bin zookeeper server start sh config zookeeper properties opt kafka bin kafka run clas
kafka
Java
kafka
大数据
分布式
kafka 应用实战
一 Java 中使用 kafka 进行通信 依赖
MQ
kafka
kafka
kafka学习(五):消费者分区策略(再平衡机制)
kafka再平衡机制 指的是kafka consumer锁订阅的topic发生变化时 发生的一种分区重分配机制 一般有三种情况会出发consumer的分区分配策略 再平衡机制 1 consumer group 中新增或删除某个consume
kafka
技术点
kafka
学习
Java
kafka消费指定每次最大消费消息数量 max.poll.records
一个属于new consumer的配置项 出现在0 10及其以上版本中 一次调用poll 操作时返回的最大记录数 默认值为500 spring kafka consumer max poll records Properties prope
kafka
Kafka使用工具封装
maven依赖
kafka
kafka
Linux Kafka 3.5 KRaft模式集群部署
这里是weihubeats 觉得文章不错可以关注公众号小奏技术 文章首发 拒绝营销号 拒绝标题党 背景 kafka在KIP 500引入了KRaft替代Zookeeper来实现自我管理元数据 详细信息可以看原文链接 KIP 500 KRaft
kafka
消息中间件
Linux
kafka
LINQ
kafka整合lua消费不到数据解决方案
用lua脚本将前端页面获取到的数据塞给kafka kafka不报错 nginx不报错 lua脚本也没有问题 topic生成了但就是消费不到数据 自己写一个生产者测试过证明消费者也没问题 折腾了很久 最后在kafka配置文件中加了host n
kafka
kafka
lua
分布式
kafka入门安装及消息发送接受初体验(附源码)
这里是weihubeats 觉得文章不错可以关注公众号小奏技术 文章首发 拒绝营销号 拒绝标题党 官方文档 https kafka apache org quickstart 版本 3 5 0 安装 这里我们提供两种安装方式 一种是编译好的
kafka
kafka
LINQ
分布式
kafka 3.5 生产者请求中的acks,在服务端如何处理源码
一 生产者客户端配置参数acks说明 1 acks 1 2 acks 0 3 acks 1 二 请求在写入Leader的数据管道之前 则会验证Leader的ISR副本数量和配置中的最小ISR数量 1 Leader的ISR小于配置文件中min
kafka
kafka