Kafka源码分析

val version = 0.9
val topic = "kafka-code"

def readKafkaCode() {
  while(true) {
    println("keep reading...")
  }
}