問題タブ [spring-cloud-stream]

@EnableBindingクラスを に変換し、次@Configurationのことが文書化されています。

@RefreshScope は @Configuration クラスで (技術的に) 機能しますが、驚くべき動作につながる可能性があります。たとえば、そのクラスで定義されているすべての @Bean がそれ自体が @RefreshScope であるとは限りません。具体的には、それらの Bean に依存するものは、それ自体が @RefreshScope (リフレッシュ時に再構築され、その依存関係が再注入される) にない限り、リフレッシュが開始されたときに更新されることに依存することはできません。リフレッシュされた @Configuration から再初期化されます)。

したがって、実際的な質問: で注釈が付けられた一部の Receiver クラスを更新する方法はまだあり@EnableBindingますか? フレームワークでは処理されず、カスタムで実装する必要があると思います@EventListener

私はイベントクラスを持っています。

destination プロパティは Kafka トピックの名前です。

宛先にメッセージを発行するにはどうすればよいですか。

宛先がプログラムで設定されているため、application.properties に宛先を入れることができません。

私は spring-cloud-stream を研究し、いくつかの問題に遭遇しました。

そしてシンク：

アプリケーションを起動するとき、 redis-cli :

問題は ：

1 : redis-cli エクスポートは "2016-04-06 12:07:19" のようにする必要がありますが、そうではありません

2: コンソール エラー:

アプリケーションhttps://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/stream-listenerを実行していますが、いくつかのエラーが発生しました。なぜですか?

コード全体とエラーの詳細はhttps://github.com/keryhu/spring-stream-transform-converterにあります

私が働いている会社は、現在のモノリシック API からマイクロサービスへの移行を調査しています。私たちの現在の API は、Spring に大きく依存しており、ほとんどの永続性のために SQL サーバーを使用しています。私たちのマイクロサービスの調査は、spring-cloud、spring-cloud-stream、kafka、および polyglot の永続性 (マイクロサービスごとに分離されたデータベース) に傾いています。

マイクロサービス アーキテクチャで通常、kafka を介したメッセージングがどのように行われるかについて質問があります。一連のマイクロサービスとクライアント アプリケーションの間に調整層を設ける予定です。これにより、さまざまなマイクロサービス間でアクティビティが調整され、マイクロサービス API への変更からクライアントが分離されます。spring-cloud-stream と kafka の使用について読んだことのほとんどは、リソースの変更操作 (挿入、更新、削除) のためにコーディネーション レイヤー (ソース) でストリームを使用する必要があることを示しています。メッセージ。

これで問題が発生したのは挿入です。データベースによって割り当てられた識別子 (ID 列/自動インクリメント列/シーケンス/代理キー) を多用し、通常はポスト リクエストの一部として割り当てられ、呼び出し元に返されます。調整レイヤーは、さまざまなマイクロサービスを使用して複数のものを保存している可能性があり、次の操作に進む前に、1 つの挿入から割り当てられた識別子が必要になることがよくあります。コーディネーション レイヤーとマイクロサービス間のメッセージングを挿入に使用すると、コーディネーション レイヤーが挿入操作からの応答を取得できなくなり、必要な割り当てられた識別子を取得できなくなります。さらに、ストリーム上の他のコンシューマー (つまり、データをデータ ウェアハウスにパブリッシュするコンシューマー) は、割り当てられた識別子をメッセージに含める必要があります。

人々はこの問題にどのように対処していますか? データベース割り当て識別子はマイクロサービスのアンチパターンですか? 非同期挿入を呼び出す前に調整レイヤーが同期呼び出しを行って識別子を取得できるように、データベースが割り当てた識別子を返す個別のマイクロサービス エンドポイントを公開する必要がありますか? UUID を使用することはできますが、DBA はそれらを主キーとして使用することを嫌い、注文番号やその他のユーザー向けの生成 ID として使用することはできませんでした。

メール（gmail）を受信するためにSpring Integration Java DSLを使用しようとしています。Redisも使用しています。メールを受信すると、 ConcurrentModificationException が発生します。検索中に、Kafka でも同じエラーが発生していることもわかりました。以下は私のコードと例外です。

助けてくれてありがとう。

例外 ：

http から mysql データベースへのストリームを作成する目的で、この URL HTTP to MySQLの例をテストしているところです。

例によると、jdbc 接続に関するすべての情報がストリーム定義で指定されています (jdbc --includes='mysql:mysql-connector-java:5.1.38' --spring.datasource.url='jdbc:mysql: //localhost:3306/Streams' --table-name=names --columns=name --spring.datasource.driver-class-name=com.mysql.jdbc.Driver --initialize=false) しかし、どういうわけか私の例は失敗しますcom.mysql.Driver クラスが見つからないと不平を言っています。

ローカルサーバー（spring-cloud-dataflow-server-local）のPOM.xmlファイルにmysqlの依存関係を追加してみましたが、運が悪かったので、java -jarコマンドを呼び出すときにクラスパスに追加しようとしました. いずれの場合も、エラーは持続します。

すべての場合において、jdbc モジュールによって表示されるエラーは次のとおりです。

誰かが私が欠けているものを指摘できますか?

ありがとう。