私は 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 ファイルを保持しているかはわかりません。
利用可能なより良い方法を提案してください。