Завершение работы сервера Кафка после продолжения записи данных в тему - PullRequest
Новая
       7

Завершение работы сервера Кафка после продолжения записи данных в тему

0 голосов
/ 29 июня 2018

когда я записываю данные в тему kafka с использованием потоковой передачи Spark Direct 2.1, через некоторое время kafka завершает работу. 

val props = new HashMap[String, Object]()     
 props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "ip:9092")   
 props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
   "org.apache.kafka.common.serialization.StringSerializer")       
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
   "org.apache.kafka.common.serialization.StringSerializer")
    val producer = new KafkaProducer[String, String](props)

   val message = new ProducerRecord[String, String](topic, partition,compression key,message)
   producer.send(message)
...