scala - パブリッシャーを使用してメッセージを生成する方法(リアクティブカフカ)?

Question

react-kafka モジュールのコードを使用する必要があります: https://github.com/akka/reactive-kafka/blob/master/README.md

私のコードは次のように始まります:

val kafka = new ReactiveKafka()

val kafkaIdpsMsgs: Publisher[StringKafkaMessage] = kafka.consume(
      ConsumerProperties(
        brokerList = kafkaHosts,
        zooKeeperHost = zkHosts,
        topic = "test",
        groupId = "idps-translator",
        decoder = new StringDecoder()
      ).readFromEndOfStream())

    val kafkaSamples: Subscriber[String] = kafka.publish(ProducerProperties(
      brokerList = kafkaHosts,
      topic = "test",
      encoder = new StringEncoder()
    ))

（出版社による）メッセージを出したい。それを実現するために書かなければならないコードは何ですか？