-1
私はkafkaのApacheログを読んでから、Spark Streamingにさらに処理したいと思います。私はkafkaを初めて使用しています。私が理解している限り、ログファイルを読み込むプロデューサクラスを作成する必要があります。kafkaのファイルからログを読み込む方法は?
私はkafkaのApacheログを読んでから、Spark Streamingにさらに処理したいと思います。私はkafkaを初めて使用しています。私が理解している限り、ログファイルを読み込むプロデューサクラスを作成する必要があります。kafkaのファイルからログを読み込む方法は?
ログファイルの各行をKafkaのトピックに変換するコネクタを作成することで、これを行うことができます。
https://docs.confluent.io/current/connect/devguide.html#connect-developing-simple-connector
をし、私は、Sparkストリーミングでこれらのログを送信するために、消費者のファイルを書き込むことができます。ここでは例をチェックしてください。 –