小编Gou*_*ury的帖子

需要了解kafka broker属性"log.flush.interval.messages"

我想了解log.flush.interval.messageskafka经纪人的设置.

在我们强制在日志上执行fsync之前写入日志分区的消息数

这是否意味着当它达到指定数量的消息时它会写入磁盘中的另一个文件?如果是这样的话:

  1. 当消费者想要阅读时,它必须从磁盘获取它,这是耗时的.它是否正确?
  2. 同时

    消息只有在从段文件刷新到磁盘后才会显示给消费者(http://notes.stephenholiday.com/Kafka.pdf)

    然后,消费者总是从磁盘读取,因为它无法从段文件中读取?

  3. 存储在段文件和磁盘上有什么区别?

apache-kafka

7
推荐指数
2
解决办法
7152
查看次数

null.==(obj)不会在scala中抛出空指针异常

我是斯卡拉的新手.请帮我理解下面的代码片段

null.==("goutam") // ---> return false
null.equals("goutam") // ---> throw NullPointerException
Run Code Online (Sandbox Code Playgroud)

根据我的理解,null是Null特征的唯一实例,它扩展了Anyref和==,并且两者都是AnyRef的函数.那么为什么第一个声明不会抛出而第二个声明呢?

scala scala-collections

4
推荐指数
1
解决办法
161
查看次数

标签 统计

apache-kafka ×1

scala ×1

scala-collections ×1