我有一个用例“XML文件==> Kafka主题==>构建REST API来查询来自kafka主题的数据 . 我熟悉将数据转换为Avro格式并写入kafka主题 .
您能否建议如何发布XML?
文件数据包含kafka主题的多个记录,在使用kafka主题的数据时,如何从Rest API访问?
我还尝试使用kafka-console-producer发布,但是为每行xml文件而不是XML记录填充键为NULL .
代码如下所示 .
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 + ")");
}
}
1 回答
使用Kafka Connect和XML transformation摄取XML文件
使用开源Confluent REST Proxy(可作为Confluent Platform或standalone的一部分提供)从Kafka主题提供数据