代码之家 › 专栏 › 技术社区 › akauppi

如何写一个卡夫卡的主题,让我得到创造的偏移回到作家?

kafka-producer-api apache-kafka

-1

akauppi · 技术社区 · 6 年前

我想用 Alpakka Kafka Connector 从一个用Scala编写的应用程序中写入Kafka主题。

Future[Done]

我想使用自动生成的偏移量,而不是维护自己的偏移量。可以有许多编写器(这是使用自动生成的另一个原因)。希望看到偏移量的原因是这样,当调用者在读取端看到该条目时,我可以允许他们进行检查。

也许这是不可能的?

1 回复 | 直到 6 年前

1

0

akauppi 6 年前

this snippet 在Alpakka-Kafka连接器文档中。

推荐文章

Hephaestus · 卡夫卡python 1.3.3:KafkaProducer。使用显式密钥发送无法将消息发送到代理

7 年前

Calvin D · asp。net core依赖项注入配置

7 年前

Gpwner · 当主线程睡眠时间小于1000时无法生成消息

7 年前

Ratha · Kafka引发java.lang.NoSuchMethodException

8 年前