AI 助理
备案控制台
开发者社区 问答 正文

KafkaConsumer是非线程安全的，那么怎么样实现多线程消费？

KafkaConsumer是非线程安全的，那么怎么样实现多线程消费？

展开
收起
芯在这 2021-12-12 10:17:02 598 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 真的很搞笑

    1.在每个线程中新建一个KafkaConsumer

    2.单线程创建KafkaConsumer，多个处理线程处理消息（难点在于是否要考虑消息顺序性，offset的提交方式）

    2021-12-12 10:17:13
    赞同 展开评论
问答分类：
安全 云消息队列 Kafka 版
问答标签：
线程多线程 线程安全线程
问答地址：
开发者社区 > 安全 > 问答
相关问答
OCR服务多线程并发有线程锁吗
111
1
0
DTS同步是单线程还是多线程
84
1
0
大家一般什么情况下使用多线程功能，怎么合理配置多线程的核心线程数？
72
1
0
函数计算FC下的python需要多线程，如何设置FC的多线程支持？
140
1
0
hygc 的多线程三色标记 gc 相较于单线程版本有哪些改进？
82
1
0
如何设置线程数以及 CountDownLatch 数，才能保证多线程是同时跑了，而不丢数据？
99
1
0
游戏服务器的多线程, 游戏客户端的多线程逻辑有什么异同?
209
1
0
JDK 8 新增的lambda、stream等相关内容可以结合多线程或者虚拟线程提升性能么？
86
1
0
阿里云E-MapReduce的jindodata写数据到oss，是单线程还是多线程阿？
134
1
0
Flink CDC同一个流中，如何设置存量读取时采用多线程，增量读取时采用单线程呢？
274
3
0