kafka-connect-spooldir：Kafka Connect连接器，用于将CSV文件读入Kafka
需积分: 42 96 浏览量
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
资源评论
