kafka连接池_python版本里面包含java的jar包由于kafka在写入时会存在并发问题,采用连接池思想,抽取一种连接池的方式,连接池是采用Apachepool作为池管理,然后将生产者的连接点放到池中,在编译时需注意kafka版本问题以及所对应的scala,kafka版本是kafka_2.10-0.8.2.1