spring-cloud-stream

0熱

1答えて

春の雲カフカストリームに非同期で書きたいと思います。例えば、 Class SomeClass{ @StreamLister(Processor.INPUT) public void receiveEvents(String e){ class ThreadExecutor implements Runnable { private String message;

0熱

1答えて

spring-cloud-starter-bus-kafka 1.2.0.RELEASEにSSL設定を提供する方法

私はSpringブート1.5.6.RELEASE、Spring Cloud Config 1.3.2.RELEASE、およびSpring Cloud Starter Bus（Kafka ）1.2.0.RELEASE、カフカ版は0.10.1.1です。私は2つのSSL対応のブローカーを使用するように設定しようとしていますが、私はこのようになります警告メッセージの反復配列（各ブローカーに1つ）になってし

0熱

1答えて

Springクラウドストリーム：SinkがRabbitMQ接続を失う

ログシンクストリームのアプリケーション依存関係のある私のカスタムSpringクラウドストリームシンクが、RabbitMQ停止中にRabbitMQ接続を失い、5回接続しようとしてから消費者を停止することがわかりました。私は手動でRabbitMQがアップしたら、それが正常に接続するために、アプリケーションを手動で再起動する必要があります。私がrabbitMQバインディングhereのデフォルトのプロパテ

0熱

2答えて

Spring Cloud Stream Processor単一入力、複数行出力

私はkafkaからjsonイベントをストリーミングしようとしていましたが、それを平坦化してから、Spring Cloud Streamを使用して別のトピックに戻しました。入力： { "major": "Computer Science", "books": [{ "title": "Learn C", "author": "Prof C" }

0熱

1答えて

Springクラウドストリームアプリのスタータープロジェクトで利用できるwebsocketソースがないのはなぜですか？

SinkのWebSocket実装がありますが、なぜSpringのクラウドストリームapp startersプロジェクトでSourceが利用できないのですか。何か特別な理由はありますか？

0熱

1答えて

SCS Kafka消費者処理のみの最新メッセージ

私はSCS 1.3.0.RELEASEを使用しています。私はプロデューサーとコンシューマーアプリケーションを持っています。コンシューマアプリケーションを起動することなく、少数のメッセージを送信するプロデューサアプリケーションを使用しました。その後、コンシューマアプリケーションを起動しましたが、メッセージは消費されませんでした。両方がアップしているときは、コンシューマアプリケーションが正しく処理され

0熱

2答えて

春のブートherokuに展開したときのcloudmaqpエラーへのバインド

herokuには1つのサービスが導入されています。私のサービスはクラウドメッセージサービスとしてcloudamqpを使用します。私のローカルenv私の接続で実行されている私のサービスが成功し、私はこのエラーが見つかりませんでした。私はherokuに私のサービスを配備するとき、私はこのエラーを持っています。 2017-10-30T06:03:05.231416+00:00 app[web.1]:

0熱

1答えて

spring-cloud-streamを使用してsleuth-kakaのトピック名を指定してください。

私はkurtkaをsleuthレポートの宛先として設定しようとしています。 sleuthがデフォルトのトピックの詐欺を送信し続けることを除いて、すべてがうまくいきます。テストのようにカスタマイズされたトピックにスパンを送ることを希望しました以下はカフカチャンネルの設定です。 spring.cloud.stream.kafka.binder.brokers=localhost:9094 spr