kafka-insert是什么?

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

kafka-insert流程介绍？

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

说明

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