Kafka客户端使用手册:基于消息事件通信的高效采集服务
下载需积分: 9 | DOCX格式 | 72KB |
更新于2024-09-14
| 187 浏览量 | 举报
Kafka 客户端手册
Kafka 客户端手册是基于 Kafka 消息队列系统的客户端使用手册,旨在为 Web 应用提供稳定高速的采集服务。该手册详细介绍了 Kafka 客户端的使用场景、设计原则、使用方法等内容。
**1. 概述**
Kafka 客户端手册基于第三方开源消息组件 Kafka 进行消息事件通信,建立在 Kafka 支持消息持久化、高吞吐、分布式等特点的基础上,为 Web 应用提供稳定高速的采集服务。开发者可以在代码中集成 Kafka-gather 客户端 jar 包,发送消息到 Kafka,从而实现消息的传播。
**1.1 适用场景**
业务信息收集,如日志采集等等。
**1.2 关联文档**
http://wiki.cnsuning.com/pages/viewpage.action?pageId=26315535
**2 设计**
**2.1 设计原则**
1. 将服务打成 jar 包对外提供服务。
2. 发送方将消息封装成约定好格式的字符串对象,将该对象以及主题(Topic)名称作为参数传入客户端发送 API 进行发送。
3. Kafka 未启动时尝试重启 Kafka 继续发送,最多重启 5 次,Kafka 发送失败时每间隔 1 分钟继续发送,最多发送 5 次。
4. 业务异常时记录异常日志。
**3 使用**
**3.1 填写 Topic 申请表**
**3.1.1 申请模板**(双击后另存为即可)
**3.2 创建 Jira 流程**
登录 http://jira.cnsuning.com/browse/MWSR 创建 Jira 流程,将步骤 1 填写的申请表作为附件上传。
**3.3 维护业务方信息**
Kafka 管理平台地址:
SIT:http://mwbopssit.cnsuning.com/(用户名/密码:工号/工号)
PRE:http://mwbopspre.cnsuning.com/(用户名/密码:工号/工号)
确认需要使用 Kafka 的系统有没有使用过 Kafka。如果是新对接的系统,请先在对应环境的 Kafka 管理平台上新建业务方,方式是:【Kafka 管理】>【业务方信息】>【新增业务方】,画面如下:
备注:
(1)填写系统负责人工号的目的是,当该工号的人员登录系统后,可以对业务方信息、Topic、告警等信息进行管理,如果是多个负责人时,则每个负责人都可以管理。
(2)APP_ID 的作用是将各个系统区分开,为后期加入权限做准备,填写表单时可以用系统英文简称。
如果已经使用过 Kafka,直接进行第 4 步,创建 Topic 记录,在创建时需要选择自己的业务方。
**3.4 创建 Topic 记录**
在对应环境的 Kafka 管理平台上申请 Topic。
Kafka 客户端手册详细介绍了 Kafka 客户端的使用方法和设计原则,为开发者提供了稳定高速的采集服务。通过该手册,开发者可以快速了解 Kafka 客户端的使用方法,提高开发效率。
相关推荐
![filetype](https://img-home.csdnimg.cn/images/20241231044930.png)
![filetype](https://img-home.csdnimg.cn/images/20250102104920.png)
![filetype](https://img-home.csdnimg.cn/images/20241231044901.png)
![filetype](https://img-home.csdnimg.cn/images/20241231044901.png)
![filetype](https://img-home.csdnimg.cn/images/20241231044901.png)
![filetype](https://img-home.csdnimg.cn/images/20250102104920.png)
![filetype](https://img-home.csdnimg.cn/images/20241231045053.png)
![filetype](https://img-home.csdnimg.cn/images/20241231044901.png)
![filetype](https://img-home.csdnimg.cn/images/20241231044955.png)
![](https://profile-avatar.csdnimg.cn/default.jpg!1)
X583098987
- 粉丝: 0
最新资源
- ASP新闻发布系统功能详解与操作指南
- Angular实践技巧:高效开发指南
- 中控考勤软件无注册类别错误的解决工具
- 实战教程:Android项目如何获取包括SIM卡在内的通讯录
- Pagina个人:搭建个人交互平台的HTML实践
- 创意模仿汤姆猫:熊猫跳舞小游戏动画体验
- 官方发布魔方播放器v1.0:英中字幕翻译与学习工具
- Android实现六边形布局与不规则按钮设计
- 小米SM8250设备通用设备树指南
- ADS8344高精度16位ADC采集程序实现
- 解决SpringMVC入门遇到的404及包缺失问题
- WEB应用程序技术实验室:文本博客网站开发实践
- 远古播放器2010:官网下载最新绿色版
- 企业实战中的代码重构与优化技巧
- PHP构建本地牛津词典及其实现优化
- 流放之路1.0.0e汉化升级与修复指南