我有一个Kafka主题，以“；”分隔我想导入一个voltdb表。
我在官方文件中没有发现任何关于更改分隔符的内容。Kafka进口商(https://docs.voltdb.com/usingvoltdb/exportimportkafka.php)，只给我两个选项：csv和tsv。
是否有任何高级配置只允许我更改分隔符？
我的部署.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>我的Kafka主题示例：
000000广告；20160202;20050202235900;18.99;99000000果酱；20160202;20150201235900;18.05;20
2条答案
按热度按时间roqulrg31#
我建议您实现自己的导入格式化程序，请参见这里的示例
要配置它，请使用此示例部署文件
sigwle7e2#
默认情况下，kafkaimporter使用csv/tsv导入格式化程序，这是一些选项，但没有分隔符的可配置选项。
您可以实现一个自定义解码器来处理其他格式。我们有一些测试代码，其中包括github上的一个示例自定义格式化程序。有一个run.sh包含一个函数jars，它将构建一个包含自定义格式化程序代码的osgi包。构建使用ant，ant使用build.xml文件。