Я читаю записи в потоковом / пакетном формате из самого файла журнала nifi-пользователя для тестового сценария и использую процессор ConvertRecord nifi для преобразования в формат Avro, а затем публикую в тему kafka с помощью процессора PublishKafka_2_0.Я также использую реестр схемы для подтверждения схемы.Так что теперь, когда записи сбрасываются на kafka, это делается как отдельный массив, а не как отдельные записи.Есть ли способ разбить записи на отдельную сущность.Я уже пробовал процессор Split Records, кажется, не подходит.Есть ли другой способ добиться этого.
- Обновлено