私は polyglot を使用して単純な python プロセッサを構築しようとしています。ポリグロットのレシピに従ったのですが、ストリームをデプロイできませんでした。この例で使用されているのと同じプロセッサを最初にデプロイしたところ、次のエラーが発生しました。
不明なコマンド ライン引数が要求されました: spring.cloud.stream.bindings.input.destination 不明な環境変数が要求されました: SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS
Traceback (most recent call last):
File "/processor/python_processor.py", line 10, in
consumer = KafkaConsumer(get_input_channel(), bootstrap_servers=[get_kafka_binder_brokers()])
File "/usr/local/lib/python2.7/dist-packages/kafka/consumer/group.py", line 353, in init
self._client = KafkaClient(metrics=self._metrics, **self.config)
File "/usr/local/lib/python2.7/dist-packages/kafka/client_async.py", line 203, in init
self.cluster = ClusterMetadata(**self.config)
File "/usr/local/lib/python2.7/dist-packages/kafka/cluster.py", line 67, in init
self._bootstrap_brokers = self._generate_bootstrap_brokers()
File "/usr/local/lib/python2.7/dist-packages/kafka/cluster.py", line 71, in _generate_bootstrap_brokers
bootstrap_hosts = collect_hosts(self.config['bootstrap_servers'])
File "/usr/local/lib/python2.7/dist-packages/kafka/conn.py", line 1336, in collect_hosts
host, port, afi = get_ip_port_afi(host_port)
File "/usr/local/lib/python2.7/dist-packages/kafka/conn.py", line 1289, in get_ip_port_afi
host_and_port_str = host_and_port_str.strip()
AttributeError: 'NoneType' object has no attribute 'strip'
Exception AttributeError: "'KafkaClient' object has no attribute '_closed'" in <bound method KafkaClient.del of <kafka.client_async.KafkaClient object at 0x7f8b7024cf10>> ignored
次に、デプロイ ストリームを介して環境とバインディングの引数を渡そうとしましたが、うまくいきませんでした。SPRING_CLOUD_STREAM_KAFKA_BINDER_BROKERS および spring.cloud.stream.bindings.input.destination パラメーターを Kafka のコンシューマーに手動で挿入すると、回避策としてストリームをデプロイできました。何が問題を引き起こしているのか完全にはわかりません。これを Kubernetes にデプロイすると何か違うのでしょうか、それとも Polyglot と Dataflow の問題ですか? これについての助けをいただければ幸いです。
再現手順: ポリグロット レシピからポリグロット プロセッサ ストリームをローカル データフロー サーバーにデプロイしてみます。また、例と同じストリーム定義を使用しています: http --server.port=32123 | python-processor --reversestring=true | ログ。
追加のコンテキスト: Docker を使用してカスタム python アプリケーションを展開する際に問題が発生したため、SPDF と Kafka のローカル インストールにストリームを展開しようとしています。