Я следил за вашим предыдущим сообщением о KafkaException: KafkaError {code = _TIMED_OUT, val = -185, str = "Превышено время ожидания контроллера"}. Я столкнулся с той же проблемой. Однако докеры я не использую. Я использую кластер ccloud. Я читал ваших слушателей Кафки - объяснил. Однако после того, как я перешел к T, я все еще испытываю ту же проблему. Скрипт python, который я использую, я также загрузил из нескольких примеров. Буду признателен за вашу помощь.
Спасибо