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