【项目实战】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

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

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈