spring-xd

24ısı

1cevap

Bahar veri-JPA kullanarak bir proje için bağımlılığımızı sahip olan bir yayla xd işlemci modülüne sahip

xd-singlenode yay-veri JPA kullanarak yay xd işlemci modülünü dağıtmak mümkün: pom.xml org.test.common ait <dependencies> <dependency> <groupId>org.test.common</groupId> <artifactId>o

0ısı

1cevap

yay xd akışı kapalı - piton modülü Bahar-xd içinde piton modülünü kullanmaya çalışıyorum ne zaman

, ben hata altına alıyorum: 10 üzerinden Tecrübelerime göre [ stream create pytest --definition "time | shell --command='python /home/Ubuntu/xd/echo2.py' --encoder=LF | log" --deploy] [] 2016-03-21

0ısı

3cevap

Rabbitmq veri yolu ile özel işlemci özel durumunu yönetme

İstisna atabilecek özel bir işlemci modülü hazırladım. Ancak özel durum oluştuğunda, stacktrace'i günlük dosyasında veya stdout'ta göremiyorum. Bu benim örnek kod: @Transformer(inputChannel = "input",

-1ısı

1cevap

Yay XD ve Koruma Kalitesi = gizlilik

Spring XD, koruma kalitesini destekliyor mu = Gizlilik? Aşağıdaki istisnayı Cloudera 5.5.2 ile ve 'hadoop.rpc.protection = privacy' olarak ayarladım. Sorun ekstra özellikler ekleyerek çözülene 2016-03

1ısı

1cevap

dinamik gecikme yapılandırma

Yoklama dinamik Ben s3.The sabit gecikme dosyaları yoklamak için entegrasyondan Anketlerimizi bileşenini kullanıyorum 15 dk ve maksimum mesaj oranı, bu aşağı akışında oldu ı did 1 hayranlarıyla nedeni

7ısı

2cevap

Apache Spark vs Spring XD Akarsular

Apache Spark akışının uygun olacağı ve Spring XD akışlarının en uygun olduğu durumları kullanmak istiyorum. Burada teknolojilerin üst üste gelmesi var mıdır? Birisi her ikisinin de kullanıldığı bir du

0ısı

1cevap

Spring-XD ile Mesaj Önceliklendirmesi

Mesaj yolu olarak RabbitMQ 3.5.7 kullanılarak 1.3.1 sürümündeyiz. Bir giriş kuyruğu aracılığıyla ileti alan bir akış için, mesaj önceliğini ayarlamak istiyorum. Amqp şablonu ve MessagePostProcessor ar

5ısı

1cevap

Bir cassandra tablosundan veri akışı nasıl yapılır?

Gerçek zamanlı olarak güncellenen bir cassandra tablosundan veri akışı yapmak istiyorum. Evet, bir veri tabanı ama bunu yapmanın bir yolu var mı? Eğer öyleyse, bir ofset tutmak veya hangi CQL sorgular