wanted_topics = ['host_updates_queue', 'foo_bar']
topics = subprocess.check_output([os.path.join(KAFKABIN, 'kafka-topics.sh'),
    '--list', '--zookeeper', '{}:2181'.format(KAFKAHOST)])
Проверьте, существует ли тема Kafka в Python