DTStack / DTStack/flinkStreamSQL

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

未關閉
#351 0 則留言 0 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Java
星號
2k
分支
913
PR 合併指標
30 天內沒有已合併 PR

描述

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

貢獻指南

這個儲存庫沒有索引到貢獻指南

研究方向

Start by tracing the Kafka-Source CSV path that uses Flink's CsvRowDeserializationSchema and the jackson-dataformat-csv API. Confirm how the current single-character delimiter is configured, then define completion as successfully parsing Kafka CSV messages with a multi-character delimiter.

由索引模型根據 Issue 內容生成。

評估

技術堆疊
java
領域
stream-processing
Issue 類型
功能
難度
4/5
預估耗時
3-5 天
活躍度
停滯
描述清晰度
基本清楚
新手友好度
35/100

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。