У меня есть потребитель kafka, который десериализует авро-сообщения и печатает на стандартный вывод.Я хочу передать вывод в файлы, но хочу отдельный файл для каждого сообщения - не все сообщения в одном файле.
Я искал в Google, и большинство людей хотят выводить в несколько файлов или передать в другую программу, это не то, что я пытаюсь сделать.Мне нужно каждое сообщение / строка в уникальное имя файла, либо со счетчиком, номером сообщения с выхода или датой до миллисекунды.
Вывод в следующем формате:
AVRO MESSAGE (1): {Data in JSON format}
AVRO MESSAGE (2): {Data in JSON format}
AVRO MESSAGE (3): {Data in JSON format}
AVRO MESSAGE (4): {Data in JSON format}
Я хочу, чтобы строка 1 входила в файл с именем output1.txt или output20190518113126104, строка 2 - в файл с именем output2.txt или output20190518113126351, где имя с меткой времени - YYYYMMDDHHmmssSSS или что-то подобное, чтобы гарантировать, что оно уникально.