queue-kafka: kafka的封装，使用scala编写