私はApache Kafkaに比較的慣れていません。小さなプロジェクトの一環として、テキスト ログ ファイルを単一のメッセージとして Kafka に配置しようとしていました。いくつかのエンコード エラーが発生しました。Kafka の Java API (私が理解しているように) には、主に文字列エンコーディングの規定が含まれています。
回避策として、各行が 1 つのメッセージを表す Kafka でログ ファイルを 1 行ずつスローしましたが、これでは最初の問題ステートメント (1 つのファイルが 1 つのメッセージ) は解決しません。