3

私は Kafka を初めて使用し、python を使用して kafka コンシューマー トピックからメッセージを読み取ろうとしています。メッセージを読むために以下のコードを使用しています。

from kafka import KafkaConsumer

topic = 'topic'
bootstrap_servers = 'server'

consumer = KafkaConsumer(bootstrap_servers = [bootstrap_servers],
               auto_offset_reset = 'earliest',
               enable_auto_commit = True,
               security_protocol = 'SASL_PLAINTEXT',
               sasl_mechanism = 'GSSAPI',
               consumer_timeout_ms = 1000)

これを実行すると、「KfW インストールが見つかりませんでした」というエラー メッセージが表示され、Kafka に接続できませんでした。Windows MSI 用の Kerberos をインストールして再実行すると、接続を確立できるようになりました。

ただし、ローカル システムでの KfW のインストールを回避しようとしています。代わりに、認証プロセスで使用する keytab ファイルとプリンシパルを渡し、kafka トピックからデータを読み取る方法を見つけます。(可能であれば?)

しかし、KafkaConsumer のどの引数が keytab ファイルを保持しているかはわかりません。

利用可能なより良い方法を提案してください。

4

0 に答える 0