共1篇
文章标签:Kafka
Kafka 是一个开源的分布式消息流平台,主要用于高吞吐量、低延迟的实时数据流处理。它能够处理大规模的实时数据流,广泛应用于日志收集、数据流管道、实时分析等场景。Kafka 基于发布-订阅模式,将消息分为主题(Topic)并存储在多个分区中,支持高效的消息传递和存储。通过生产者将数据发送到 Kafka,消费者从 Kafka 中读取数据,Kafka 提供了强大的数据存储、分发、处理能力,适用于大规模分布式系统。
初学 Kafka:Python 接入 Kafka 的基本操作与实战
最近有个运维需求,目的是对接一个第三方平台的告警事件到我们平台。对接的那个平台会把告警事件推送到他们的 Kafka,我们需要从 Kafka 中获取数据,处理后接入到我们的平台。由于我熟悉 Python,但对 Kafka 比较陌生,因此决定通过这篇文章记录一下我...
最近有个运维需求,目的是对接一个第三方平台的告警事件到我们平台。对接的那个平台会把告警事件推送到他们的 Kafka,我们需要从 ...
昨日热榜
- new-api 重试配置最佳实践:RetryTimes 与状态码范围
- Chrome 浏览器插件离线下载与安装指南
- 使用 Cloudflare 搭建自己的 Docker Hub 镜像代理
- 主流 AI Agent 技能与配置加载机制横评
- 用 kkFileView 搭一个文件在线预览服务
- new-api 网关改写实战:param_override 与 header_override 的两个坑
- new-api 分流与重试降级实战:三个免费渠道如何做到逐级兜底
- Clash Verge 添加直连规则:让 VPN 流量不被代理劫持
- 智能体 Skill 创建标准完全指南 — 基于 Agent Skills 规范
- 飞牛 NAS 安装 MoonTV
文章分类
标 签 云
Django
Docker
Nginx
后端开发
Linux
Go
踩坑
容器化
工作经验
docker-compose
Python爬虫
shell
ChatGPT
Requests
MySQL
CI/CD
Jenkins
Agent
Redis
Git
PVE
AI
数据库
SSH
pip
Celery
定时任务
ITSM
API网关
new-api
Virtualenv
多线程
CentOS
markdown
MongoDB
SSL证书
Github
AGENTS.md
最佳实践
AI 编程
Gunicorn
crontab
Vue.js
YAML
GitHub Actions
DevOps
OpenAI
Prometheus
Grafana
图床
查看更多 ...