标签:阻塞 timeout 一个 ops lock col topic 没有 kafka
props.put("consumer.timeout.ms", "100");
这个配置很重要,关乎取消息的阻塞的时间
默认-1,consumer在没有新消息时无限期的block。如果设置一个正值, 一个超时异常会抛出
标签:阻塞 timeout 一个 ops lock col topic 没有 kafka
原文地址:https://www.cnblogs.com/erdanyang/p/11120025.html