首页 文章

Kafka Producer将消息从XML文件发布到Kafka主题

提问于
浏览
0

我有一个用例“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 回答

相关问题