产生消息时在alpakka-kafka连接器中使用的传递是什么?

问题描述 投票:0回答:1

这是在文档https://doc.akka.io/docs/alpakka-kafka/current/producer.html中给出的向Kafka生成单个消息的代码>

val single: ProducerMessage.Envelope[KeyType, ValueType, PassThroughType] =
  ProducerMessage.single(
    new ProducerRecord("topicName", key, value),
    passThrough
  )

您能解释一下passThrough的作用是什么?

这是在文档https://doc.akka.io/docs/alpakka-kafka/current/producer.html val单中提供的向Kafka生成单个消息的代码:ProducerMessage.Envelope [KeyType,ValueType,。 ..

scala apache-kafka akka-stream reactive alpakka
1个回答
0
投票

[passThrough是一个附加值,可以在ProducerMessage.ResultspassThrough()中使用。

© www.soinside.com 2019 - 2024. All rights reserved.