# kafka_connector

**Repository Path**: wangjianyu88/kafka_connector

## Basic Information

- **Project Name**: kafka_connector
- **Description**: kafka connector示例demo
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2020-06-05
- **Last Updated**: 2021-07-21

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

[项目背景]

kafka connector连接文件和hadoop的示例程序。
本服务包括：kafka-connector-file 和 kafka-connector-hdfs；每个模块又分source和sink。
[分支说明]

master: 主干稳定分支
dev: 开发分支
custom-***: 定制项目分支    
[代码结构]

|---src-bin
|   |---connector-config-curl.txt             //各connector配置命令     
|---src-main-java                             //java代码主目录      
|   |---com.xdja.kafka.file                   //kafka connector对文件读写
|       |---sink                              //kafka的topic中读取记录写入文件
|       |---source                            //文件中读取内容写入kafka的topic
|   |---com.xdja.kafka.hdfs                   //kafka connector对hadoop读写
|       |---sink                              ///kafka的topic中读取记录写入hadoop
|       |---source                            //暂无实现 
|---pom.xml                                   //pom文件
|---README.md                                 //readMe
|
[编译/打包]

mvn assembly:assembly
[外链]

暂无，随后将笔记更新的到confluence
[其他]

无