私はアプリケーションログの取り込みのための単純なパイプラインを設定する作業をしています。 このパイプラインの前提条件は、トランスポートプロトコルとしてkafkaを使用することです。 私が理解しているように、flumeにはログファイルを取り込む機能が組み込まれています。 flumeをプロデューサーとして使用し、その出力をkafkaトピックに渡す方法はありますか？flumeをカフカプロデューサとしてログの取り込みに使用できますか？
はい、FlumeをKafkaのプロデューサとして使用できます。 Flumeが提供するこのAPIをご覧ください。https://flume.apache.org/releases/content/1.6.0/apidocs/org/apache/flume/sink/kafka/KafkaSink.html
はい、利用できます。前の応答で指定されているとおりです。
# Sources, channels, and sinks are defined per
# agent name, in this case flume1.
flume1.sources = kafka-source-1
flume1.channels = hdfs-channel-1
flume1.sinks = hdfs-sink-1
# For each source, channel, and sink, set
# standard properties.
flume1.sources.kafka-source-1.type = org.apache.flume.source.kafka.KafkaSource
flume1.sources.kafka-source-1.zookeeperConnect = ...
はちょうどあなたがと同様の構成を行う必要があることを追加したいです