Kafka 在旧版本中是用 Scala 编写的吗?并且只有 Java 用于较新的版本?(用 Scala 编写的旧代码不再使用?)如果是,为什么要更改?
还是 Scala 和 Java 还在使用?如果是这样,为什么 Kafka 两者都使用?
(我不是问我是否可以用 Scala 或 Java 编写生产者或消费者。我知道 Kafka 客户端可以用多种语言编写。)
核心模块和 Kafka Streams Scala 包装器目前仍在 Scala 中
客户端(从 0.9 开始)、Kafka Connect 和主要的 Streams API 使用 Java
为什么Kafka同时使用两者?
通常是因为 Scala 具有更好的函数式 API 和对象类型语义,在(之前的)Java 版本中更难使用。
您可以在此处查看所有代码 - https://github.com/apache/kafka
| 归档时间: |
|
| 查看次数: |
3123 次 |
| 最近记录: |