# datastash

**Repository Path**: seawenc/datastash

## Basic Information

- **Project Name**: datastash
- **Description**: 功能类似logstash，只是比它轻很多,后续将提供多种outputs与inputs，现只支持kafka input,tcp output
- **Primary Language**: Java
- **License**: LGPL-3.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2023-05-05
- **Last Updated**: 2025-09-02

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 数据转发

## 介绍 
功能类似logstash，只是比它**轻量**(内存占用100M左右,运行包18M),**扩展简单灵活**（扩展一个插件只需30-100行左右的代码）



## 运行环境
jdk11,gradle7.4

## 配置示例

参考： [datastash.properties](config/datastash.properties)

## 支持插件

### input类型插件
* kafka: 接收kafka中的数据
* udp： 开启udp端口，接收从客户端发送的数据
* 
### output类型插件
* jdbc： 支持将数据输出到数据库，接收格式支持json与csv
* tcp: 支持将数据输出到tcp服务端，接收格式支持json与csv
* http: 支持将数据输出到http接口，接收格式支持json
* kafka: 支持将数据推送到kafka，接收格式支持字符串

## 打包方式
```shell script
# 出包:
gradle :dgp-app:app-data-forward:shadowJar
```

## 运行方式
```bash
# 默认读取当前目录下的datastash.properties配置文件
java -jar *.jar 
```