这是在文档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,。 ..
[passThrough
是一个附加值,可以在ProducerMessage.Results
的passThrough()
中使用。