旧 Kafka 是用 Scala 编写的,而新 Kafka 是用 Java 编写的吗?

Jin*_*Lee 8 apache-kafka

Kafka 在旧版本中是用 Scala 编写的吗?并且只有 Java 用于较新的版本?(用 Scala 编写的旧代码不再使用?)如果是,为什么要更改?

还是 Scala 和 Java 还在使用?如果是这样,为什么 Kafka 两者都使用?

(我不是问我是否可以用 Scala 或 Java 编写生产者或消费者。我知道 Kafka 客户端可以用多种语言编写。)

cri*_*007 7

核心模块和 Kafka Streams Scala 包装器目前仍在 Scala 中

客户端(从 0.9 开始)、Kafka Connect 和主要的 Streams API 使用 Java

为什么Kafka同时使用两者?

通常是因为 Scala 具有更好的函数式 API 和对象类型语义,在(之前的)Java 版本中更难使用。

您可以在此处查看所有代码 - https://github.com/apache/kafka