spring-xd

5熱

1答えて

cassandraテーブルからデータをストリームする方法は？

リアルタイムで更新されるcassandraテーブルからデータをストリーミングしたいと思います。はい、それはデータベースですが、それを行う方法はありますか？もしそうなら、私はオフセットを保持するか、CQLのクエリを使用できますか？

cassandra streaming spark-streaming spring-xd bigdata 2016-02-29

---

1熱

1答えて

spring-xd custom redis-sink

spring-xdで提供されている現在のredis-sinkを拡張して、新しいリストを作成するのではなく、Redis Cappedリストに書き込む必要があると思いますが、残念ながら私がredis-sink全体がredisの一般的なpub/sub抽象化に基づいているように見えるため、ばね統合（spring-data-redis）に深く入り込む必要があります。メッセージがチャネルハンドラに到着すると定

spring-integration spring-xd spring-data-redis 2016-03-20

---

0熱

1答えて

春-XDストリームが閉じ - Pythonモジュール

私はエラーの下に取得しています、春-XDでのpythonモジュールを使用しようとしている時はいつでも：、私の経験で [ stream create pytest --definition "time | shell --command='python /home/Ubuntu/xd/echo2.py' --encoder=LF | log" --deploy] [] 2016-03-21T1

spring-xd 2016-03-21

---

0熱

3答えて

Rabbitmqバスでカスタムプロセッサ例外を管理します

例外をスローするカスタムプロセッサモジュールを作成しました。 例外が発生すると、スタックトレースがログファイルまたはstdoutに表示されません。 これは私のサンプルコードです： @Transformer(inputChannel = "input", outputChannel = "output") public String transform(final String payload)

rabbitmq spring-xd 2016-03-22

---

-1熱

1答えて

Spring XDと保護の質=プライバシー

Spring XDは保護の質=プライバシーをサポートしていますか？私は以下のCloudera 5.5.2の例外とプロパティを 'hadoop.rpc.protection = privacy'に設定しました。 2016-03-25T16:22:38+0100 WARN Spring Shell o.a.h.i.Client:673 - Couldn't setup connection for [

kerberos spring-xd 2016-03-25

---

0熱

1答えて

モジュール内からSpring XDモジュールのメタデータを取得する方法

ModuleMedatadaにアクセスする必要があるSpring XDモジュールを作成しました。 メタデータはZooKeeperModuleMetadataRepositoryで取得できますが、実行中のモジュールを一意に識別する方法はまだわかりません。サンプルモジュールを考える ：モジュールは独自のコンテキストを持っていることが強調されるplugin documentationで @Message

spring spring-xd 2016-03-25

---

1熱

1答えて

ダイナミック遅延設定

ポーリング動的 私はs3.The固定遅延からファイルをポーリングする統合からポーラー・コンポーネントを使用しています は15分と最大メッセージレートが、これはダウンストリームにいた私は1つの【選択の理由です私はHTTPを使用して以来、xdのメッセージが詰まっていました。これは100kレコードファイルのファイルですが、ファイルサイズが小さいときは、私はfast.Nowを処理することができますが、まだ

spring-integration spring-xd 2016-03-30

---

0熱

1答えて

、私のメッセージを私はペイロードとして</p> <p>はメッセージ全体を運ぶ「{$のpayload.routingkeyを」} <br> を使用してSpringXDにRabbitMQのシンクのroutingkey値を設定しようとしていますRabbitMQの

のための春のXDにおける動的ルーティングのキーを指定する方法JSON {：「ディズニー」、「テキスト」：「routingkey」「DisneyTweet」}である しかし、それは java.lang.IllegalArgumentException: Could not resolve placeholder 'payload.routingKey' in string value "${payl

rabbitmq spring-xd 2016-03-31

---

0熱

3答えて

springXDでHTTPクライアントの投稿要求を送信するには

私は自分のローカルでrestfull webserviceプロジェクトを実装しました。残りのクライアントからリクエストを送信でき、また応答を得ています。以下 は残り、クライアントの "POSTリクエスト" である： {"address":{"type1":"abc","email":"[email protected]"}} 応答： {"address":{"type1":"abc","ema

java spring spring-xd 2016-04-01

---

1熱

1答えて

Spring XDの「サイドチャネル」でメッセージを送信する方法は？私はこのような何かを達成したいと思い

：いくつかのプロセッサがWICH後 [Source] --> [Splitter] --B--> [Processor] --B--> [Aggregator] ---> [Sink] | ^ | | |--------------------C-------------------| は特別なプロデューサーは、

java spring spring-integration spring-xd 2016-04-07

---