問題タブ [confluent-kafka-python]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
python - Kafka トピックからメッセージを受信しない
このプログラムで poll() を呼び出すと None を受け取りますが、cmd から kafka-console-consumer.bat を実行するとメッセージが表示されます。正確に何が問題なのかわかりません。
実行は main.py から始まります
KafkaDiscoveryExecutor クラスは、共有キューからメッセージを消費し、そのメッセージを処理するためのものです。
これは kafka_message_consumer.py です
指定されたトピックにはイベントがありますが、ここで None が取得され、'if msg is None:' 内の print ステートメントが実行されています。
python - Python confluent-kafka パッケージの戻り値が「ApiVersion のリクエスト中に切断されました」を返す
環境OS：macOS
Python ライブラリ confluent_kafka==1.7.0
外部カフカ ブローカー バージョン 2.6.1
セキュリティ プロトコルを指定しません。すべてがデフォルトの PLAINTEXT です。
これを実行
「ApiVersionのリクエスト中に切断されました」というエラーが返されます
Kafka ツールのような別のツールとkafka-python のような別の python パッケージを使用するのにうんざりしています。それは機能していますが、confluent_kafka は機能していません。
デバッグ情報
%7|1637327168.507|BROKER|rdkafka#consumer-1| [thrd:app]: GroupCoordinator: NodeId -1 %7|1637327168.507|BROKER|rdkafka#consumer-1| で新しいブローカーを追加しました [thrd:app]: my-external-host:9092/bootstrap: NodeId -1 %7|1637327168.507|BRKMAIN|rdkafka#consumer-1| で新しいブローカーを追加しました [thrd:GroupCoordinator]: GroupCoordinator: メイン ブローカ スレッドを入力してください %7|1637327168.507|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: メイン ブローカ スレッドに入る %7|1637327168.507|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#consumer-1 初期化済み (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STRIP STATIC_LINKING CC GXX PKGCONFIG OSXLD LIBDL プラグイン ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW、デバッグ 0x2) %7|1637327168。507|接続|rdkafka#consumer-1| [thrd:main]: my-external-host:9092/bootstrap: クラスター接続用に選択: コーディネーター クエリ (ブローカーの接続試行は 0 回) %7|1637327168.507|BRKMAIN|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: メイン ブローカー スレッドを入力 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: CONNECT op %7|1637327168.507|STATE|rdkafka#consumer-1| を受け取りました [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:app]: クラスター接続用のブローカーを選択していません: まだ 49 ミリ秒抑制されています: アプリケーション メタデータ要求 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:アプリ]: クラスター接続用のブローカーを選択していません: 49 ミリ秒の間まだ抑制されています: アプリケーション メタデータ要求 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: TRY_CONNECT 接続状態のブローカー %7|1637327168.507|STATE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:app]: クラスター接続用のブローカーを選択していません: まだ 49 ミリ秒抑制されています: アプリケーション メタデータ要求 %7|1637327168.509|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: ソケット 11 %7|1637327168.578|CONNECT|rdkafka#consumer- で ipv4#10.103.68.24:9092 (平文) に接続しています1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: ipv4#10.103.68.24:9092 %7|1637327168.578|CONNECTED|rdkafka#consumer-1| に接続しました [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 接続済み (#1) %7|1637327168.578|FEATURE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 有効なプロトコル機能 +ApiVersion を ApiVersion %7|1637327168.578|STATE|rdkafka#consumer-1| に更新しました [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1637327168.578|CONNECT|rdkafka#consumer-1| [thrd:app]: クラスター接続は既に進行中です: アプリケーション メタデータ要求 %7|1637327168.580|FAIL|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: ApiVersion の要求中に切断されました: security.protocol 構成が正しくない (SSL リスナーに接続していますか?) またはブローカーのバージョンが < 0.10 (api.version.request を参照) (状態 APIVERSION_QUERY で 2ms 後) (_TRANSPORT) %6|1637327168.580|FAIL|rdkafka# が原因である可能性があります消費者-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: ApiVersion の要求中に切断されました: security.protocol 構成が正しくない (SSL リスナーに接続していますか?) またはブローカーのバージョンが原因である可能性があります< 0.10 (api.version.request を参照) (状態 APIVERSION_QUERY で 2 ミリ秒後) %7|1637327168.580|FEATURE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 有効なプロトコル機能 -ApiVersion を %7|1637327168.580|STATE|rdkafka#consumer-1| に更新しました [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: