Kafka：有没有用于 scala 的 Kalfa 客户端 API？

Question

我刚开始使用Kafka，它听起来对微服务非常好，但我基本上是在Scala中工作的。

我将kafka添加到我的sbt项目中：

libraryDependencies += "org.apache.kafka" %% "kafka" % "2.0.0"

然后我这样做:

import org.apache.kafka.clients.producer.{Callback,KafkaProducer, Producer}

...

val producer = new KafkaProducer[String, String](props)
val record = new ProducerRecord[String, String]("my-topic", "key", "value")
val fut = producer.send(record, callBack)
...

我这里的问题是，当我调用生产者时，我没有得到Scala未来。发送，它是Java的未来。我不知道Java Futures是如何工作的，我更愿意跳过这个学习曲线。这次是未来，但我指的是Java。

所以我想知道是否有完整的Scala api可以和Kafka一起使用。因为Kafka是用Scala写的，所以通常应该是这样。

Answer 1

从Kafka到2.0.0的显着变化

> < li>

自0.11.0.0起已被弃用的Scala消费者已被移除。从0.10.0.0开始，Java消费者就是推荐的选项。请注意，即使代理升级到2.0.0，1.1.0(及更早版本)中的Scala消费者仍将继续工作。

自0.10.0.0以来已弃用的Scala生产者已被删除。Java生产者自0.9.0.0以来一直是推荐的选项。请注意，Java生产者中默认分区程序的行为与Scala生产者中的默认分区程序不同。迁移的用户应考虑配置一个保留先前行为的自定义分区程序。请注意，即使代理升级到2.0.0,1.1.0（及更早版本）中的Scala生产者仍将继续工作。