У меня есть сценарий использования "XML-файл ==> Тема Kafka ==> Построить REST API для запроса" данных из тем Кафки. Я знаком с преобразованием данных в формат Avro и пишу в кафку тему.
Не могли бы вы предложить, как опубликовать XML?
Файл данных содержит несколько записей для темы кафки, а при использовании данных из тем кафки, как получить доступ из Rest API?
Я также пытался опубликовать с помощью kafka-console -roduction, но ключ заполнялся как NULL для каждой строки XML-файла вместо XML-записи.
код выглядит следующим образом.
producer.sendMessage(linenum, line);
public static final String fileName = "testfolder/memberdetails.xml";
public void sendMessage(String key, String value) {
producer.send(
new ProducerRecord<String, String>(topicName, key, value))
System.out.println("Sent message: (" + key + ", " + value + ")");
}
}