@KafkaListener(topics = {"CRBKC0002.000"})
public void sendSmsInfoByBizType(String record) {
}
假设单机版的kafka,就一个节点。
1、 @KafkaListener注解接受消费者,是不是等这个方法执行完。
这个消费者进程才算消费结束。是不是一个镜像这个方法同时只能执行一次?就是不能连续起多个线程执行这个方法。
2、如果接受到参数就算消费这进程结束,也就是获取这个record消费者进程就结束了,那假设生产者一秒生产100w数据进入kafka。那这边获取参数就算消费者进程消费结束,那是不是相当于瞬间连续起100w这个方法线程执行。可是tomcat就200线程。
kafka消费者速度与什么有关
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-