1

我对使用 LinkedIn 的 camus 很陌生,并且已经成功地将数据文件从 Kafka 写入 Hdfs。通常,我使用JsonStringMessagdecoder读取 JSON 并将其写入.dat文件使用StringRecordWriterProvider.

但是可以写入多种文件类型吗?

假设 jsonkafka如下:

{ "user":"John", "message":"Hi how are you?" }

现在我想John,Hi how are you?写入一个文件,同时user,message写入.meta同一位置的另一个文件()。可能吗 ?

4

0 回答 0