码迷,mamicode.com
首页 > 其他好文 > 详细

kafka的配置

时间:2019-07-02 13:29:18      阅读:81      评论:0      收藏:0      [点我收藏+]

标签:阻塞   timeout   一个   ops   lock   col   topic   没有   kafka   

1、kafka的配置

2、topic的配置

3、producer的配置

4、consumer的配置

props.put("consumer.timeout.ms", "100");

这个配置很重要,关乎取消息的阻塞的时间

默认-1,consumer在没有新消息时无限期的block。如果设置一个正值, 一个超时异常会抛出

kafka的配置

标签:阻塞   timeout   一个   ops   lock   col   topic   没有   kafka   

原文地址:https://www.cnblogs.com/erdanyang/p/11120025.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!