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