【项目实战】Java 开发 Kafka 生产者
Kafka 生产者是指使用 Apache Kafka 的应用程序,用于向 Kafka 集群发送消息。生产者将消息发布到 Kafka 主题(topic),然后消费者可以从该主题订阅并接收这些消息。Kafka 生产者是实现消息发布的一方,可以是任何编程语言中的应用程序。
Offset Explorer中添加Kafka连接
offset explorer中Kafka链接
什么是kafka,如何学习kafka,整合SpringBoot
什么是kafka,如何学习kafka,整合SpringBoot
Kafka 可视化工具 Kafka Tool
Kafka 可视化工具 Kafka Tool
kafka为什么尽量使用手动提交
kafka为什么尽量使用手动提交
springboot 集成 kafka批量消费数据
kakfa 批量消费 手动提交
flink 实时数仓构建与开发[记录一些坑]
flink 实时数仓构建与开发
springboot多kafka配置
【代码】springboot多kafka配置。
【运维笔记】kafka跨域通信代理
网络跨域情境下,kafka集群通过nginx代理互访
Kafka可视化管理工具kafka-manager部署安装和使用
Kafka可视化管理工具kafka-manager部署安装和使用
【kafka】记一次kafka磁盘空间爆满问题处理
解决kafka 的__consumer_offsets 磁盘空间占用过多问题
kafka简单介绍
kafka是一个分布式的,支持数据分区,多副本,基于zookeeper协调的分布式消息系统。上个文章介绍了rabbitmq,他和kafaka的最大区别就是kafak是分布式的,并发处理能力强大。broker:消息中间处理节点,一个kafka节点就是一个broker,可以组成集群produce:生产者
kafka基础选择题
kafka基础选择题
Kafka单机版部署说细教程
因为项目中要使用KAFKA,自己搭建一个单机版,作测试服务器使用,已经过测试,可以使得,分享级需要的朋友。
springboot:整合Kafka
springboot:整合Kafka
[springboot配置Kafka] springboot配置多个kafka,包含账号密码
springboot 配置多个kafka
flink开发常见问题 —— flink-kafka 依赖版本冲突问题
flink kafka 连接配置项目总结
k8s kafka部署实战
使用 k8s 提供的命令行工具 kubectl 创建 Kafka Service,将 Kafka 集群暴露在 k8s 集群外部。使用 Kafka 提供的命令行工具来测试 Kafka部署后,可以使用 Kafka 提供的命令行工具来测试 Kafka 是否正常工作。这个文件定义了一个 Service,将
Kafka最基础使用
这样可以明显减少系统资源的浪费,例如:之前consumer0、consumer1之前正在消费某几个分区,但由于rebalance发生,导致consumer0、consumer1需要重新消费之前正在处理的分区,导致不必要的系统开销。但是低级API,比较复杂,需要执行控制offset,连接到哪个分区,并
Kafka系列之消息重新消费
Kafka消息重新消费;通过kafka-consumer-groups.sh脚本修改offset;通过新增group