Kafka:scala 有 Kalfa 客户端 API 吗? [英] Kafka: Is there a Kalfa clients API for scala?

问题描述

我刚刚开始使用 Kafka，这对微服务来说听起来非常好，但我基本上在 Scala 中工作.

I am just starting with Kafka, it sounds really good for Microservices, but I work essentially in Scala.

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

I added kafka to my sbt project with this:

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)
...

我的问题是，当我调用 producer.send 时，我没有得到 Scala Future，它是 Java Future.我不知道 Java Futures 是如何工作的，我宁愿跳过那个学习曲线.这次是 Future，但我的意思是一般的 Java.

My problem here is that I am not getting a Scala Future when I call producer.send, it is a Java Future. I don't know how Java Futures work, and I would prefer to skip that learning curve. This time it is Future, but I mean Java in general.

所以我想知道是否有一个完整的 Scala api 可以与 Kafka 一起使用.通常应该是这种情况，因为 Kafka 是用 Scala 编写的.

So I am wondering if there is a full Scala api to work with Kafka. It should normally be the case since Kafka is written in Scala.

推荐答案

来自 Kafka 2.0 的显着变化.0

• 自 0.11.0.0 起已弃用的 Scala 使用者已被删除.自 0.10.0.0 以来，Java 使用者一直是推荐的选项.请注意，即使代理升级到 2.0.0，1.1.0(及更早版本)中的 Scala 使用者仍将继续工作.

• The Scala consumers, which have been deprecated since 0.11.0.0, have been removed. The Java consumer has been the recommended option since 0.10.0.0. Note that the Scala consumers in 1.1.0 (and older) will continue to work even if the brokers are upgraded to 2.0.0.

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

The Scala producers, which have been deprecated since 0.10.0.0, have been removed. The Java producer has been the recommended option since 0.9.0.0. Note that the behaviour of the default partitioner in the Java producer differs from the default partitioner in the Scala producers. Users migrating should consider configuring a custom partitioner that retains the previous behaviour. Note that the Scala producers in 1.1.0 (and older) will continue to work even if the brokers are upgraded to 2.0.0.

这篇关于Kafka:scala 有 Kalfa 客户端 API 吗?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！