kafka_Demo.zip

通过python采用多进程读取kafka信息。 在配置文件中可以配置kafka的topic，是否启用，ip，port等信息。 每次读取后，会将读取到的消息id持久化到文件中，下次程序启动时，会继续从此id续读。