Поддержка коннектора kafka-connect-hdfs для сохранения массива байтов и разделения полей с использованием схемы FlatBuffer

Я искал поддержку коннектора kafka-connect-hdfs (Confluent) для сохранения массива байтов и разделения полей с использованием схемы FlatBuffer.

Я получаю данные в массиве байтов от kafka. Этот массив байтов генерируется из FlatBuffer. Нужно сохранить его в HDFS по пути, скажем, Field1/Field2/Field3. Все эти поля должны быть извлечены из массива байтов с использованием схемы FlatBuffer. Кроме того, данные, которые должны быть сохранены в HDFS, должны быть только в байтах. Преобразование данных не требуется.

Я проверил оба:

1. Разделитель поля: https://github.com/confluentinc/kafka-connect-storage-common/blob/master/partitioner/src/main/java/io/confluent/connect/storage/partitioner/FieldPartitioner.java
2. Поддерживаемые форматы: Json, Avro, Parquet. В https://github.com/confluentinc/kafka-connect-storage-cloud/blob/master/kafka-connect-s3/src/main/java/io/confluent/connect/s3/format/json/JsonRecordWriterProvider.java, хотя я нахожу байтовый массив, сохраненный в HDFS, если данные имеют тип Kafka Struct.

Я не мог найти способ использовать их для моей цели.

Кто-нибудь знает о такой встроенной поддержке. Если нет, то, пожалуйста, направьте меня к ресурсу (если есть), чтобы создать индивидуальную поддержку для обоих.