Voltdb - Kafka Importer - Change delimiter zum importieren

Question

Ich habe ein Kafka-Thema durch ";" und ich möchte in eine voltdb-tabelle importieren.

Ich habe in der offiziellen Dokumentation nichts über die Änderung des Trennzeichens gefunden. Der Kafka Importer (https://docs.voltdb.com/UsingVoltDB/exportimportkafka.php), gib mir nur zwei Möglichkeiten: CSV und TSV.

Gibt es eine erweiterte Konfiguration, die es mir erlaubt, nur das Trennzeichen zu ändern?

Mein 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> 

Beispiel meines Kafka Thema:

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

Answer 1

Der KafkaImporter verwendet standardmäßig einen CSV/TSV Import Formatter, der als few options, aber keine konfigurierbare Option hat s für das Trennzeichen.

Sie können einen benutzerdefinierten Decoder für andere Formate implementieren. Wir haben einen Testcode, der ein Beispiel für einen benutzerdefinierten Formatierer auf Github here enthält. Es gibt eine run.sh, die eine Funktion enthält, die ein OSGI-Paket mit dem benutzerdefinierten Formatierungscode erstellt. Der Build verwendet ant, das die Datei build.xml verwendet.

Answer 2

Ich würde Ihnen empfehlen, implementieren Sie besitzen Import Formatierer Beispiel here

sehen, diesem Beispiel konfigurieren verwenden deployment file