java Kafka与Spring集成consumertimeout与读取超时?
配置
使用spring integration kafka Extension和以下配置:
<int-kafka:zookeeper-connect id="zookeeperConnect"
zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000"
zk-session-timeout="10000" zk-sync-time="2000" />
<int-kafka:consumer-context id="consumerContext" consumer-timeout="5000" zookeeper-connect="zookeeperConnect">
timeout
是等待消息的时间,还是等待消息并阅读消息的时间?该值与读取超时不同吗
共 (0) 个答案