0

0.9.0.0 から KafkaClient 0.10.0.1 に移行しようとしています。コードは 0.9.0.0 で本番環境で正常に動作しています。コンシューマーが次の例外 javax.servlet.ServletException: java.lang.NoSuchMethodError: org/apache/kafka/clients/consumer/KafkaConsumer.subscribe(Ljava/util/List;) で開始されると、開発プラットフォームの同じコードが例外をスローするようになりました。 V (ファイル:/home/vcap/app/wlp/usr/shared/config/lib/global/kafka-clients-0.10.0.1.jar から com.ibm.ws.classloading.internal.AppClassLoader@7a0d5027 によってロード) が呼び出されましたクラス com.ibm.b2b.msghub.helper.AbstractB2BConsumer から (com.ibm.ws.classloading によってファイル:/home/vcap/app/wlp/usr/shared/config/lib/global/B2BBlueMixLib-1.0.jar からロードされます) .internal.AppClassLoader@7a0d5027)。

マドゥ

4

1 に答える 1

1

クライアント API は、Kafka 0.9 と 0.10 の間でわずかに変更されました。

KafkaConsumer.subscribe() の定義が変更されました。最初の引数は、List ではなく Collection 型になりました。

これは、API の一貫性を高めるために行われました。以前は複数の型が混在していましたが、ほとんどの (すべて?) 呼び出しが Collection オブジェクトを受け取るようになりました。

于 2016-10-06T08:46:45.070 に答える