私は通常scalaを使用します2.10.x。私が制御できないコンポーネントのいくつかの制限のため、kafkaクライアントバージョン0.7.2を使用する必要があります。ただし、このバージョンはkakfascala ver 2.9.2でのみコンパイルでき、scala2.10では動作しません。注：新しいバージョンのkafkaは使用できません。機能していません。実際のkafkaバージョンを制御できないため、このクライアントバージョンを使用する必要があります。だから私はkafkaクライアント0.7.2を使用する必要があります
だから私は複数のオプションがありました：
0.7.2kafkaクライアントのソースをダウンロードし、scalaでコンパイルすると、2.10残念ながらソースの変更が多すぎて実行できません。jarajarして更新scala-library.jarし、のようなパッケージにプレフィックスを付けscala.* -> scala.29.*ます。次に、kafkaクライアント0.7.2を更新して、クラスをインポートします。scala.29.*これを試してみましたが、ここでも問題が発生しました。.warTomcatが異なるクラスローダと異なる戦争をロードするように、私は私の元からではなく、私のカフカ要求を送信することができ、私のTomcatのWebサーバにwar私からにwar1するwar2とwar2、単純なWebになりますシンプルなアプリを保持しkafka client 0.7.2ます。私の質問：オプション3は賢明に聞こえますか？複数のクラスローダーの問題を解決するために複数あるという理由だけでGETリクエストを送信した場合、そのオーバーヘッドについていくつかの考えがあります。localhostwars
最終的にkafkaクライアント0.7.2をscala2.10でコンパイルしましたが、難しくはありませんでした。すべてが機能します。
この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。
侵害の場合は、連絡してください[email protected]
コメントを追加