# kafka-insert

**Repository Path**: wangzonghui/kafka-insert

## Basic Information

- **Project Name**: kafka-insert
- **Description**: 高效kafka入库软件，以zmq为数据源，Disruptor为消息队列。
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2018-01-03
- **Last Updated**: 2024-05-01

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## kafka-insert是什么?
kafka-insert是一个高效的kafka入库项目，接收zmq数据，Disruptor存储数据，kafka入库，最高效率可达到3G每秒。


## kafka-insert流程介绍？
* 首先启动定时任务，配置文件指定日志打印周期，显示单位时间内发送数据大小和发送次数。
* zmq pull模式接收数据，传送给Disruptor，Disruptor发送kafka入库。
* 多线程kafka批量入库，每次连接最小发送条数为配置文件中row属性


## 说明
kerberos认证，必须先由kakfa安装包进行服务器认证，再代码认证才能通过。
欢迎反馈意见和建议。