python - pykafka:オフセットマネージャーの検出中にソケットが切断されました

Question

これは私のコードです： ここに画像の説明を入力してください

実行すると、次のような警告が表示されます: オフセット マネージャーの検出中にソケットが切断されました。そのため、Ctrl+C を使用して停止します。次に、 ここに画像の説明を入力します。

あなたの助けが必要なのですが、どうすればいいですか? どうもありがとうございました！