def kafka_install(self):
with cd('<STR_LIT>'):<EOL><INDENT>if not exists('<STR_LIT>'):<EOL><INDENT>sudo('<STR_LIT>'.format(<EOL>bigdata_conf.kafka_download_url<EOL>))<EOL><DEDENT>sudo('<STR_LIT>')<EOL>sudo('<STR_LIT>'.format(bigdata_conf.kafka_home))<EOL>sudo('<STR_LIT>'.format(bigdata_conf.kafka_home))<EOL><DEDENT>
kafka download and install
:return: