# mydataharbor-kafka

**Repository Path**: mydataharbor/mydataharbor-kafka

## Basic Information

- **Project Name**: mydataharbor-kafka
- **Description**: 该项目是为MyDataHarbor实现kafka的DataSource 和 Sink，让使用者可以从kafka抽取数据，或者将数据写入kafka。
- **Primary Language**: Java
- **License**: MPL-2.0
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 3
- **Forks**: 2
- **Created**: 2021-08-28
- **Last Updated**: 2024-02-21

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# mydataharbor-kafka
# 作者

MyDataHarbor([1053618636@qq.com](mailto:1053618636@qq.com))

# 项目介绍

该项目是为MyDataHarbor实现kafka的DataSource 和 Sink，让使用者可以从kafka抽取数据，或者将数据写入kafka。

# 实现版本

| 中间件/协议 | 数据源（DataSource） | 写入源（Sink） |
| ----------- | -------------------- | -------------- |
| kafka       | ✅全部版本            | ✅全部版本      |

# 配置

## DataSource配置

```json
{
    "topics": [],
    "kafkaConfig": {}
  }
```

## Sink配置

```json
{
    "topic": "",
    "kafkaConfig": {},
    "sync": true
  }
```