私のプロジェクトでは、camus は長い間使用されており、更新されることはありません。camus プロジェクトは、kafka バージョン 0.8.2.2 を使用します。kafka 1.0.0 を使用するための回避策を見つけたいです。
そのため、ディレクトリを複製して依存関係を更新しました。これを行うと、 Message here には追加のパラメーターhereが必要です。
上記の github リンクに示されているように、コードはコンパイルされますが、ここの条件により、メッセージは kafka から読み取られません。
適切なデータコンストラクターとともにkafka依存関係を更新して機能させることは可能ですかkafka.message.Message?