Я использую пример объединения потоков Python Kafka, приведенный в этом, API потокового Python Kafka
Я могу генерировать данные, используя файл generator.py, указанный в winton-kafka-streams/ examples / binning /, тогда как когда я запускаю файл binning.py из той же папки, у меня возникает следующая проблема.Может ли кто-нибудь помочь мне, чтобы решить эту проблему?
Вы можете найти полныйскрипт в кафка биннинг скрипт и журнал ошибок