問題タブ [spring-cloud-stream]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
java - Spring Cloud Stream Kafka レコードが大きすぎます
Spring Cloud Stream を介して Kafka 経由でかなり大きな (> 4 mb) メッセージを送信しようとしているアプリケーションがあります。現在、次のエラーが発生しています。
org.apache.kafka.common.errors.RecordTooLargeException: このメッセージはシリアライズ時に 4280852 バイトであり、max.request.size 構成で構成した最大要求サイズよりも大きくなっています
Spring Cloud Stream プロデューサーに「max.request.size」を設定する方法はありますか?
spring-xd - Spring Cloud Data Flow で kafka ソースからのデータを消費する際の例外
ソースとしてkafkaトピックを試すと、kafka例外が発生します
これが私がストリームを作成した方法です
実行中にログファイルで例外が発生します
このプロパティを設定すると言及されているいくつかのスレッドを見ました-「spring.cloud.stream.bindings.input.consumer.headerMode = raw」が役立ちますが、どういうわけかこれは機能しません。
spring-cloud - スプリング クラウド ストリームを使用する場合に、タービンを使用してクラスター内の hystrix メトリックを集約する方法
spring-cloud-stream (Kafka バスを使用) を使用するように hystrix/turbine セットアップを変更したいと考えています。変更は非常に簡単で、すべての hystrix 回路とメトリックをダッシュボードに表示できます...しかし、クラスターのグループ化は機能しなくなりました...
古いセットアップでは、 my に次のプロパティがありますboostrap.yml。
私のタービン設定は次のようになります：
現在kafkaバスを使用しているため、eurekaはもう使用されておらず、これは議論の余地があると思いますが、クラスター名を設定する方法が今はわかりません...アプリ名の前にクラスターを付けることができます名前を付けて clusterNameExpression を使用してプレフィックスを抽出しますが、もっと簡単にできることがあるかもしれません...何かアイデアはありますか?
編集 1: clusterNameExpression を使用できません ... spring-cloud-starter-turbine-stream では使用できません ...
編集 2 : spring-cloud-starter-turbine-stream はタービン 2 を使用するように見えますが、spring-cloud-starter-turbine はタービン 1 を使用します。タービン 2 は構成の点で本当に異なります...