게시자를 사용하여 메시지를 생성하는 방법 (reactive-kafka에서)?

Question

나는 반응성 카프카 모듈에서 코드와 함께 일해야 :

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

내가 (게시자에 의해) 메시지를 생성하려면 : https://github.com/akka/reactive-kafka/blob/master/README.md

내 코드로 시작합니다. 코드 작성을 위해 작성해야하는 코드는 무엇입니까?

Answer 1

val done = Source(1 to 100) 
    .map(_.toString) 
    .map { elem => 
    new ProducerRecord[Array[Byte], String]("topic1", elem) 
    } 
    .runWith(Producer.plainSink(producerSettings)) 

이 문서를 통해 갈 수

: http://doc.akka.io/docs/akka-stream-kafka/current/producer.html