Voltdb - Kafka Importer - Изменить разделительный элемент, использованный для импорта

Question

У меня есть тема kafka, ограниченная символом ";" и я хочу импортировать в таблицу voltdb.

Я не нашел в официальной документации что-либо об изменении разделителя. Импортер Kafka (https://docs.voltdb.com/UsingVoltDB/exportimportkafka.php) дает мне только два варианта: CSV и TSV.

Есть ли расширенная конфигурация, которая позволяет мне изменять только разделитель?

Мой deployment.xml:

<import> 
    <configuration type="kafka" enabled="true" format="csv"> 
     <property name="topics">br-com-topic-ws</property> 
     <property name="procedure">AUT.insert</property> 
     <property name="brokers">liXXXX:9092</property> 
    </configuration> 
</import> 

Пример моего Кафки Тема:

000000ADS; 20160202; 20050202235900; 18,99; 99 000000JAM; 20160202; 201502; 18.05; 20

Answer 1

KafkaImporter по умолчанию использует CSV/TSV Import Formatter, который как few options, но не имеет настраиваемой опции s для разделителя.

Вы можете реализовать пользовательский декодер для обработки других форматов. У нас есть тестовый код, который включает пример пользовательского форматирования на Github here. Существует run.sh, который включает в себя функциональные банки, которые будут строить пакет OSGI, содержащий специальный код форматирования. В сборке используется ant, в котором используется файл build.xml.

Answer 2

Я бы рекомендовал вам реализовать у вас есть импорт форматировщик см пример here

настроить его использовать этот пример deployment file