在我提出问题之前,我想指出这里已经提出了一个类似的问题,但尚未得到解答,因此我再次提问。请不要将此标记为重复,因为前面提到的问题没有任何答案。
我对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=500,consumer.poll(200)以及fetch.min.bytes= 500但是券商没有足够的数据以恢复为集fetch.min.bytes?
我正在尝试学习Shell脚本,并且遇到了ANSI-C Quoting。我知道,反冲转义序列将由ANSI-C标准解码。根据链接,echo $'\n'应打印单个换行符。我不明白为什么要echo $'\n'打印两个换行符?