wie man kafkaproducer kontinuierlich laufen lässt

Question

Ich habe kafkaproducer in Java geschrieben, um Protokolle zu lesen. Aber nach dem Lesen von Protokollen wird der Prozess beendet, wie kann ich Kafkaproducer dazu bringen, kontinuierlich zu laufen. Ich möchte nicht, dass Kafkaproducer nach dem Lesen von Protokollen angehalten wird.

Answer 1

Die Logik ist nicht auf Kafka verwandt, aber Sie müssen kontinuierlich Daten in die Datei hören, wie folgt:

BufferedReader br = new BufferedReader(
      new FileReader("/path/to/log.txt")); 

    String line = null; 
    while (true) { 
     line = br.readLine(); 
     if (line == null) { 
      //wait till more data is appended to file 
      Thread.sleep(1000); 
     } 
     else { 
      //send data to Kafka 
      producer.send(new ProducerRecord<String, String>("my-topic", "my-key", line)); 
     } 
    } 

Answer 2

Verwenden Kafka-Log Appender die Protokolle an den zentralen Broker zu umlenken.

https://logging.apache.org/log4j/2.x/manual/appenders.html#KafkaAppender