confluent-schema-registry

0熱

1答えて

spring-kafka 2.0.0.Releaseを使用していて、コンフルエントなスキーマレジストリを使用してメッセージをデシリアライズするソースを作成した人はいますか？私が解決しようとしている問題は、MongoDBのイベントを発生させるkafka接続プラットフォームにDebezium CDCコネクタがあることです。私はそれらのイベントを変換して再ストリームを傍受する必要があります。イベントを

0熱

1答えて

Kafkaコネクタ例外エラーHTTP要求をエンドポイントに送信できませんでした：http：// localhost：8081/subjects/jdbc-source-accounts-value/versions

コネクタを起動しているときにConfluent Platform 3.3をKafkaコネクタとして使用しています以下のコマンドを使用して、 ./bin/connect-standalone ./etc/schema-registry/connect-avro-standalone.properties ./etc/kafka-connect-jdbc/connect-jdbc-source.pro

0熱

1答えて

AvroシリアライザとスキーマレジストリでKafkaにメッセージを送信する方法

AvroシリアライザとスキーマレジストリでKafkaにオブジェクトを送信しようとしています。ここは単純化されたコードです： Properties props = new Properties(); ... props.put(KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSe

0熱

1答えて

カフカストリーム - GenericAvroSerde

上の不明な魔法のバイトカフカストリームとアブロデータをストリーミングしようとしたとき、私はこのエラーに出くわした： Exception in thread "StreamThread-1" org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id -1 Caused

0熱

1答えて

スキーマレジストリのインストール方法

コンフルエントなスキーマレジストリをインストールするオプションがあります。レジストリを単独でダウンロードしてインストールし、既存のkafkaセットアップと連携させることは可能ですか？おかげ

0熱

1答えて

クラスタモードでコンフルエントKafkaスキーマレジストリを設定する方法

セットアップ： - AWS ELBの背後に3つのスキーマレジストリインスタンスがあります。 schema_registry.propertiesファイルを変更してクラスタ・モードでスキーマ・レジストリを設定する方法 ELBエンドポイントでスキーマレジストリを呼び出しています。