我的 Kafka 消費(fèi)者的輪詢速度比我預(yù)期的要快。是否有一些配置我可以更改以使其一直等待fetch.max.wait.ms？我將 fetch.max.wait.ms 設(shè)置為某個(gè)秒數(shù) (5)。我設(shè)置fetch.min.bytes了一些大字節(jié)數(shù) (99,988,800)。我閱讀了文檔（但可能遺漏了一些內(nèi)容）：https://kafka.apache.org/documentation/獲取.min.bytes服務(wù)器應(yīng)為獲取請(qǐng)求返回的最小數(shù)據(jù)量。如果可用數(shù)據(jù)不足，則請(qǐng)求將等待積累足夠多的數(shù)據(jù)，然后再回答請(qǐng)求。1 字節(jié)的默認(rèn)設(shè)置意味著一旦單個(gè)字節(jié)的數(shù)據(jù)可用或獲取請(qǐng)求在等待數(shù)據(jù)到達(dá)時(shí)超時(shí)，就會(huì)立即響應(yīng)獲取請(qǐng)求。將其設(shè)置為大于 1 的值將導(dǎo)致服務(wù)器等待大量數(shù)據(jù)的積累，這可以稍微提高服務(wù)器吞吐量，但會(huì)增加一些額外的延遲。fetch.max.wait.ms如果沒有足夠的數(shù)據(jù)立即滿足 fetch.min.bytes 給定的要求，服務(wù)器在回答獲取請(qǐng)求之前將阻塞的最長時(shí)間。fetch.max.wait.ms=5000, fetch.min.bytes=99988800根據(jù)我的配置選項(xiàng)和數(shù)據(jù)集，我希望調(diào)用poll在返回任何記錄之前始終阻塞 5 秒。相反，對(duì) 的調(diào)用poll有時(shí)會(huì)在不到一秒的時(shí)間內(nèi)解決，并且總是有一些少量的記錄。這是示例運(yùn)行的輸出：// send 100 records// doesn't matter how// timestamp -> records received// (date, hour and minute are not shown, just the relevant seconds.millis)32.475 -> 1033.392 -> 1234.116 -> 1637.477 -> 1638.395 -> 1839.118 -> 1742.479 -> 743.397 -> 4沒有延遲真的接近5s。