小编kar*_*ani的帖子

fetch.max.wait.ms 与 poll() 方法的参数

在我提出问题之前,我想指出这里已经提出了一个类似的问题但尚未得到解答,因此我再次提问。请不要将此标记为重复,因为前面提到的问题没有任何答案。

我对fetch.max.wait.ms和有疑问consumer.poll(<value>)。这是我在对上述配置的研究中发现的

poll() 方法采用超时参数。这指定了 poll 需要多长时间才能返回,有或没有数据

如果您将 fetch.max.wait.ms 设置为 100 ms 并将 fetch.min.bytes 设置为 1 MB,Kafka 将收到来自消费者的 fetch 请求,并在有 1 MB 数据要返回时或在 100 之后响应数据ms,以先发生者为准。

所以我的问题是,会发生什么情况fetch.max.wait.ms=500consumer.poll(200)以及fetch.min.bytes= 500但是券商没有足够的数据以恢复为集fetch.min.bytes

apache-kafka kafka-consumer-api

5
推荐指数
3
解决办法
4000
查看次数

为什么回显$'\ n'打印2行?

我正在尝试学习Shell脚本,并且遇到了ANSI-C Quoting。我知道,反冲转义序列将由ANSI-C标准解码。根据链接,echo $'\n'应打印单个换行符。我不明白为什么要echo $'\n'打印两个换行符?

linux bash shell

-1
推荐指数
1
解决办法
45
查看次数

标签 统计

apache-kafka ×1

bash ×1

kafka-consumer-api ×1

linux ×1

shell ×1