使用sql实现kafka生产者和消费者