SpringXD 和集成：桥接、可轮询和可订阅通道答案

【问题标题】：SpringXD and Integration: Bridge, polleable &subscribable channelsSpringXD 和集成：桥接、可轮询和可订阅通道
【发布时间】：2017-08-08 05:27:27
【问题描述】：

我正在阅读 Spring Integration 文档以了解如何使用 polleable and subscribable channels（这将是我的 SpringXD 模块之一）实现桥接。

所以the documentation related to the bridge 基本上说，我应该这样做：

http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd">

<channel id="pollable" />
<bridge input-channel="pollable" output-channel="subscribable">
    <poller max-messages-per-poll="10" fixed-rate="5000" />
</bridge>
<channel id="subscribable" />

然后我正在创建一个 SpringXD 流，例如：

stream create source-customBridge-sink-testing --definition "kafka-source:kafka --zkconnect=localhost:2181 --topic=first-queue | custom-bridge | kafka-sink:kafka --topic=regular-queue" --deploy

但我得到了：

2017-03-16T12:52:06-0300 1.3.0.RELEASE INFO DeploymentSupervisor-0 zk.ZKStreamDeploymentHandler - 流“source-customBridge-sink-testing”的部署状态：DeploymentStatus{state=failed,error(s )=org.springframework.beans.factory.BeanCreationException: 创建名为 'org.srin 的 bean 时出错 gframework.integration.config.ConsumerEndpointFactoryBean#0'：调用 init 方法失败；嵌套异常是 java.lang.IllegalArgumentException：不应为端点 'org.springframework.integration.config.ConsumerEndpointFactoryBean#0' 指定轮询器，因为 'pollable' 是 Subscrib。

我错过了什么？

【问题讨论】：

标签： spring spring-integration spring-xd

【解决方案1】：

您缺少pollable 必须声明为的问题：

<channel id="pollable">
    <queue/>
</channel>

【讨论】：