spring-xd

0热度

1回答

当XD shell/XD-container意外退出并且作业仍处于部署状态时，我多次观察到此错误。当xd容器和xd-shell重新启动时，它不允许我们用相同的名称重新创建作业。但它在工作清单中也没有看到。作为解决方法，我们使用新名称创建作业。有没有这个问题的解决方案。我认为这只发生在Windows上的XD上，但它似乎也发生在Unix机箱上。 springXD job error

1热度

1回答

SpringXD/Spring集成：使用不同版本的弹簧集成 - 卡夫卡对生产者和消费者

我有以下配置： Spring的集成 - 卡夫卡1.3.1.RELEASE 我有一个自定义卡夫卡水槽和一个自定义的卡夫卡源的配置我想有：我想仍然使用Spring-integration-kafka 1.3.1.RELEASE和我自定义的kafka-sink。我改变了我的卡夫卡型逻辑使用Spring的集成 - 卡夫卡2.1.0.RELEASE。我注意到实现消费者/生产者的方式与先前版本的Spri

0热度

1回答

SpringXD：自动启动=虚假不工作的卡夫卡消息驱动通道适配器

我使用SpringXD，我有以下配置：弹簧集成 - 卡夫卡2.1.0.RELEASE 卡夫卡客户0.10.0.1 卡夫卡0.10.xx 弹簧XD-1.3.1.RELEASE 我在我的xml文件以下配置： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans

0热度

2回答

Spring XD无法找到RabbitMQ ConnectionFactory的类定义

我正在从xd-singlenode模式切换到分布式，使用版本1.3.1-RELEASE。我在Docker容器中运行Spring XD，其中有Dockerfile similar to the one here。根据XD guide，如果我想使用RabbitMQ作为我的数据传输，那么我需要配置一个servers.yml文件。我有RabbitMQ在一个单独的码头集装箱中运行，并将这两个集装箱作为码头

0热度

1回答

方法调用：方法toObject（java.util.LinkedHashMap中）不能对org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

我面对春季XD了以下问题和的GemFire nested exception is org.springframework.expression.spel.SpelEvaluationException: EL1004E:(pos 8): Method call: Method toObject(java.util.LinkedHashMap) cannot be found on org.spr

0热度

1回答

弹簧数据流w/2源提供一个处理器/接收器

我正在寻找建立一个特定用例的Spring数据流流的建议。我的使用情况：我有2 RDBMS，我需要比较针对每个运行的查询的结果。查询应该大致同时运行。根据比较结果，我应该可以通过我创建的自定义电子邮件接收器应用程序发送电子邮件。我设想流图看起来像这样（对不起，油漆）：的问题是，日本自卫队没有，据我所知，允许流与2个源组成。在我看来，像这样的事情应该是可能的，而不必将框架的限制推得太远。我正在

0热度

2回答

Gemfire CacheListenerAdapter实现ClassNotFoundException：org.apache.geode.pdx.internal.PdxType

当我试图从gemfire实现CacheListenerAdapter时出现以下错误。 java.lang.ClassNotFoundException: org.apache.geode.pdx.internal.PdxType 我使用下面的代码从获得的GemFire缓存值。 import com.gemstone.gemfire.cache.Declarable; import com.gems

0热度

1回答

从SpringXD迁移到Spring云数据流

我们目前正在使用SpringXD将数据从各种数据源提取到接收器。由于Springxd预定可用性结束，我们希望迁移到Spring Cloud数据流。我们已经写了几个自定义模块SpringXD。如何在SCDF中使用相同的模块。在SCDF中使用这些变化需要做什么修改。我们的群集配置了kerberos，SCDF支持kerberized kafka和hadoop吗？在运行时在纱线中使用服务器时是否有任

1热度

1回答

springxd流使用HDFS数据集来保存avro数据无法更新kerberos票据

我创建了一个springxd流====>源JMS队列 - >转换 - 自定义Java处理器（XML到AVRO） - >接收器 - HDFS -Dataset。流工作正常，但24小时后，因为它的连续连接，它无法更新kerberos身份验证票并停止写入HDFS。我们正在重新启动这个流部署的容器，但仍然面临问题并丢失消息，因为它们甚至不会发送到redis错误队列。我需要帮助 - 如果我们能够续约流K

1热度

2回答

弹簧XD Redis的水槽与收藏型MAP

我试着去实现Redis的特定于集合类型下沉= MAP stream create tTEST_GF_SINK --definition "trigger --initialDelay=0 --fixedDelay=1 --timeUnit=MINUTES --payload= 'new Date().toString()' --outputType=application/json |