kafka-connect-spooldir：Kafka Connect连接器，用于将CSV文件读入Kafka
需积分: 42 165 浏览量
2021-02-03
21:06:20
上传
评论
收藏 212KB ZIP 举报
kafka-connect-spooldir：Kafka Connect连接器，用于将CSV文件读入Kafka （125个子文件） 
DataHasMoreFields.data 5KB DataHasMoreFields.data 5KB FileModeFieldFieldsMatch.data 5KB FieldsMatch.data 5KB SourceOffset.data 5KB SchemaHasMoreFields.data 4KB DataHasMoreFields.data 2KB FileModeFieldFieldsMatch.data 2KB WithHeaderSkipLines.data 2KB BlankLines.data 2KB FieldsMatch.data 2KB SourceOffset.data 2KB WithoutHeader.data 2KB SchemaHasMoreFields.data 2KB FieldsMatch.data 683B DataHasMoreFields.data 45B .gitignore 80B SpoolDirCsvSourceConnectorConfig.java 18KB AbstractSourceConnectorConfig.java 16KB AbstractSpoolDirSourceConnectorConfig.java 13KB AbstractSourceTask.java 9KB AbstractSpoolDirSourceTaskTest.java 8KB AbstractSchemaGenerator.java 8KB InputFile.java 7KB SpoolDirCsvSourceTask.java 6KB SpoolDirCsvSourceTaskTest.java 6KB LogFieldConverterFactory.java 5KB AbstractSpoolDirSourceConnector.java 5KB AbstractCleanUpPolicy.java 5KB InputFileDequeue.java 4KB SpoolDirJsonSourceTask.java 4KB SchemaConversionBuilderTest.java 4KB SpoolDirJsonSourceConnector.java 4KB SpoolDirCsvSourceConnector.java 4KB SpoolDirELFSourceTask.java 3KB AbstractSpoolDirSourceTask.java 3KB Metadata.java 3KB AbstractSpoolDirSourceConnectorTest.java 3KB SchemaConversionBuilder.java 3KB package-info.java 3KB FileComparatorTest.java 3KB AbstractCleanUpPolicyTest.java 3KB TestDataUtils.java 3KB SpoolDirSchemaLessJsonSourceTask.java 3KB SpoolDirJsonSourceConnectorTest.java 3KB SpoolDirCsvSourceConnectorTest.java 3KB SpoolDirELFSourceConnector.java 3KB CsvSchemaGeneratorTest.java 3KB JsonSchemaGeneratorTest.java 2KB SpoolDirCsvSourceConnectorConfigTest.java 2KB CsvSchemaGenerator.java 2KB AbstractTaskPartitionerPredicate.java 2KB SpoolDirELFSourceTaskTest.java 2KB SpoolDirSchemaLessJsonSourceConnector.java 2KB SpoolDirBinaryFileSourceConnector.java 2KB FileComparator.java 2KB SpoolDirLineDelimitedSourceTask.java 2KB JsonSchemaGenerator.java 2KB SpoolDirJsonSourceTaskTest.java 2KB SpoolDirBinaryFileSourceTask.java 2KB SchemaConversion.java 2KB SpoolDirSchemaLessJsonSourceConnectorConfig.java 2KB SpoolDirLineDelimitedSourceConnectorConfig.java 2KB AbstractSourceConnector.java 2KB SpoolDirLineDelimitedSourceConnector.java 2KB TimestampLogFieldConverter.java 2KB MinimumFileAgePredicateTest.java 2KB AbstractSchemaGeneratorTest.java 2KB LogFieldConverter.java 2KB SpoolDirSchemaLessJsonSourceTaskTest.java 2KB LocalTimeLogFieldConverter.java 1KB MoveByDateCleanupPolicyTest.java 1KB TestCase.java 1KB LocalDateLogFieldConverter.java 1KB SpoolDirBinaryFileSourceTaskTest.java 1KB ByNameAbstractTaskPartitionerPredicateTest.java 1KB ProcessingFileExistsPredicateTest.java 1KB DeleteCleanupPolicyTest.java 1KB SpoolDirELFSourceConnectorConfig.java 1KB SpoolDirJsonSourceConnectorConfig.java 1KB SpoolDirBinaryFileSourceConnectorConfig.java 1KB MoveCleanupPolicyTest.java 1019B PrimitiveLogFieldConverter.java 1003B DocumentationTest.java 829B NamedTest.java 770B NoneCleanupPolicyTest.java 732B Jenkinsfile 161B FileModeFieldFieldsMatch.json 128KB FileModeFieldFieldsMatch.json 128KB WithHeaderSkipLines.json 128KB DataHasMoreFields.json 128KB DataHasMoreFields.json 128KB SchemaHasMoreFields.json 127KB SchemaHasMoreFields.json 127KB WithoutHeader.json 127KB FieldsMatch.json 127KB FieldsMatch.json 127KB BlankLines.json 127KB SourceOffset.json 71KB SourceOffset.json 64KB共 125 条
- 1
- 2
资源评论
活着奔跑
- 粉丝: 35
- 资源: 4685
最新资源
- 毕业设计-仿生六足机器人的制作全教程源码+电子元器件+程序代码+线路组件图+安装教程+搭建视频教程
- 基于ROS和webots的xrobot机械臂仿真初探C++源码
- 基于ROS的点焊机器人仿真与控制python源码+文档说明+使用说明+详细注释
- 基于vue实现的细粒度交通时空大数据分析系统+源代码+文档说明
- 安卓大作业-基于Electron的交通时空大数据分析挖掘系统客户端(Android)+源代码+文档说明+界面截图
- 基于Java的朱氏集团客户关系管理系统设计源码
- 基于C++的作业提交与批改系统设计源码
- 基于Vue2的移动端电影资讯网站设计源码
- 高分课程设计作业-基于QT的模仿宝石迷阵游戏C++源码+文档说明+界面截图
- 基于Apache Spark的Spark DistCP重实现设计源码
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
