Для чего используется это сообщение у встроенного производителя кафки? - PullRequest
Новая
       52

Для чего используется это сообщение у встроенного производителя кафки?

0 голосов
/ 26 октября 2019

Это встроенная функция производителя kafka для создания производителя. Какая польза от сообщения, поскольку оно не используется и поскольку запись будет производиться с использованием ProducerRecord

    def kafkaProducer[K, T](topic: String, key: K, message: T)(
      implicit config: C,
      keySerializer: Serializer[K],
      serializer: Serializer[T]) =
    new KafkaProducer[K, T](baseProducerConfig.asJava,
                            keySerializer,
                            serializer)

например - 

val producer
      = kafkaProducer("dell","tommy","What is this message")(config,new StringSerializer,new StringSerializer)

val record: ProducerRecord[String, String] 
= new ProducerRecord[String,String]("dell","This is the message")

producer.send(record)
...