問題タブ [confluent-schema-registry]

現在、スキーマ レジストリ 1.0.1 から 2.0.1 へのアップグレードを試みています。これは、次のバージョンでアップグレードする前に機能していることがわかります: kafka_2.10 バージョン 0.9.0.2.4.0.0、kafka-avro-serializer バージョン 2.0.1、avro バージョン 1.7.7

アップグレード後、以前に成功した同じリクエストが HTTP 404 エラーで失敗するようになりました。

CURL で確認したところ、例を使用してスキーマを投稿できました。

次に、Avro schema: "string" が問題である可能性があると考えたため、ThingKey スキーマを作成しましたが、同様のエラーが引き続き発生します。

次のコードを使用してメッセージを公開しています。

アイデアや提案は大歓迎です。

ありがとう、ロス

更新: 修正済み - この問題は、バージョン 2.0.1 でのより厳密な検証のために失敗を引き起こしているリクエスト パスの追加のスラッシュが原因でした。完全な詳細: https://github.com/confluentinc/schema-registry/issues/388

Kafka Broker クラスターをセットアップし、いくつかのトピックを作成した後、次の 2 つのトピックが Kafka によって自動的に作成されることがわかりました。

1. __consumer_offsets
2. _schema

これらのトピックの重要性と用途は何ですか?

私のトピックにオブジェクトをシリアルKafkaProducer化するために使用できます。KafkaAvroSerializerただし、シリアル化されたクラスではなく、KafkaConsumer.poll()逆シリアル化されたものが返されます。GenericRecord

MyKafkaProducer

私のカフカ消費者

MyBean bean = record.value();その行は、GenericRecord を MyBean にキャストできないため、キャスト例外をスローします。

を使用してkafka-client-0.9.0.1いkafka-avro-serializer-3.0.0ます。

avro ペイロードを kafka-rest サービスに発行するときに、value_schema のフィールドの 1 つがデフォルト値で定義され、records でこのフィールドが省略されている場合。kafka-rest はまだレコード内に保持することを主張しているようです。そうする正しい方法は何ですか？

例えば。

出力

0.9 kafka に接続するには、confluent schema-registry を使用する必要があります。しかし、schema-registry 2.0.1 バージョンでは、利用可能な SSL 構成が表示されませんでした。schema-registry と kafka-rest の ssl が 0.9 kafka と通信できるようにする方法はありますか?

Can AVRO schemas be registered with confluent schema registry service ?

As per readme on github https://github.com/confluentinc/schema-registry

Every example uses a JSON schema with a single field and type without any name.

I am trying to store following schema to repository but with different variants getting different error.

Or