Skip to content

joeyhacker/kafka-client

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 

Repository files navigation

kafka-client 构建目标: 配置相关:

  1. 读取配置文件,连接zookeeper,注册连接中诸多配置信息
  2. 实现消息发送和消费的基本封装;消费线程数配置等
  3. 数据分区基本实现

辅助功能:

  1. consumer宕机后重连生成一致的id (读取配置或按照一致算法生成)
  2. 消费者负载均衡 broker的增减 topic的增减 broker与topic的关联变化

About

mls kafka 客户端访问包

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Java 100.0%