cxb332211 2019-11-07 20:30 采纳率: 14.3%
浏览 1015
已结题

kafka消费者速度与什么有关

@KafkaListener(topics = {"CRBKC0002.000"})
public void sendSmsInfoByBizType(String record) {
}
假设单机版的kafka,就一个节点。
1、 @KafkaListener注解接受消费者,是不是等这个方法执行完。
这个消费者进程才算消费结束。是不是一个镜像这个方法同时只能执行一次?就是不能连续起多个线程执行这个方法。
2、如果接受到参数就算消费这进程结束,也就是获取这个record消费者进程就结束了,那假设生产者一秒生产100w数据进入kafka。那这边获取参数就算消费者进程消费结束,那是不是相当于瞬间连续起100w这个方法线程执行。可是tomcat就200线程。

  • 写回答

2条回答 默认 最新

  • threenewbee 2019-11-07 22:48
    关注
    评论

报告相同问题?

悬赏问题

  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 对于相关问题的求解与代码
  • ¥15 ubuntu子系统密码忘记
  • ¥15 信号傅里叶变换在matlab上遇到的小问题请求帮助
  • ¥15 保护模式-系统加载-段寄存器
  • ¥15 电脑桌面设定一个区域禁止鼠标操作
  • ¥15 求NPF226060磁芯的详细资料