Apache Kafkaを介してLogstashに接続する方法は？KafkaからElasticsearchのようなものにそれをどのように取得するかという質問が必然的に出てきます。誰かがこれを行うためのtutoを持っていますか？
ありがとうございました
Logstashには、kafka用の入力プラグインがあります。まず、apache kafkaと彼のプロデューサー/コンシューマーパラダイムに精通する必要があります：https：//kafka.apache.org/。次に、Logstashの使用を開始します：https：//www.elastic.co/products/logstash 。このすべての後、logstash用のkafka入力プラグインを使用できるようになります：https：//www.elastic.co/guide/en/logstash/current/plugins-inputs-kafka.html 。最後のステップは、Elasticsearchなどの宛先にデータを挿入するためのlogstashパイプラインを構築することです。この簡単な例は、目標を達成するのに役立ちます。
logstash.conf
input {
kafka {
bootstrap_servers => "localhost:9092"
topics => ["example-topic"]
}
}
output {
elasticsearch {
hosts => ["localhost:9200"]
index => "example-index"
}
}
ここでは、特定のトピックに関するkafkaキューからのデータを取得します。次に、データをelasticsearchインデックスに保存します。お役に立てば幸いです。
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加