DTStack / DTStack/flinkStreamSQL

Kafka-Source Csv格式下,多字符支持

Open
#351 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
2k
Forks
913
PR merge metrics
No merged PRs in 30d

Description

目前,Kafka-Source插件csv数据格式,用于读取kafka消息,使用的是flink官方的CsvRowDeserializationSchema(调用jackson-dataformat-csv的API进行解析),只支持单字符分隔符。是否考虑添加多字符分隔符。这个应该很实用!!!

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.