Kafka之消费与激情(4)
发布时间:2021-05-29 18:39 所属栏目:118 来源:互联网
导读://andavoidblockwaitingfortheirresponsestoenablepipeliningwhiletheuser //ishandlingthefetchedrecords. // //NOTE:sincetheconsumedpositionhasalreadybeenupdated,wemustnotallow //wakeupsoranyothererrorsto
// and avoid block waiting for their responses to enable pipelining while the user // is handling the fetched records. // // NOTE: since the consumed position has already been updated, we must not allow // wakeups or any other errors to be triggered prior to returning the fetched records. (编辑:ASP站长网) |
相关内容
网友评论
推荐文章
热点阅读