Golang教程网
博客首页
实战学习Golang
日常工作实战
小程序实战开发
微信小程序开发
百度智能小程序开发
QQ小程序开发
头条小程序开发
支付宝小程序开发
学习笔记
搜索
搜索
go kafka 多线程消费
学习笔记
2023-01-20
166°
前提:本例适合那些没有顺序要求的消息主题。
kafka
通过一系列优化,写入和读取速度能够达到数万条/秒。通过增加分区数量,能够通过部署多个
消费
者增加并行
消费
能力。但还是有很多情况下,某些业务的执行速度实在是太慢,这个时候我们就要用到
多线程
去
消费
,提高应用机器的利用率,而不是一味的给
kafka
增加压力。使用Spring创建一个
kafka
消费
者是非常简单的。我们选择的方式是继承
kafka
的Shutdow
相关链接
kafka消费异步确认保证数据不丢失
关于golang:Go语言如何操纵Kafka保证无消息丢失
kafka消费者组重平衡悬疑问题
golang kafka client
Golang删除Kafka中某个主题的所有记录
在线Golang文档阅读GoHub.zip