-
4 votesanswersviews
Spring Integration Kafka适配器不生成消息
我现在正在奋斗这几天 . 我在Spring-boot容器下使用SI适配器用于kafka . 我在我的机器上配置了zookeeper和kafka . 我还创建了控制台 生产环境 者和消费者测试它,一切正常(我设法生成控制台消息并让控制台消费者使用它们) . 我现在尝试通过Spring集成kafka出站适配器生成消息,但控制台消费者不会使用该消息 SI / Spring xd xml: <int... -
1 votesanswersviews
Spring XD Kafka源没有注册为消费者?
部署以下Spring XD流后: “kafka --topics = rm-sdrs --outputType = text / plain --zkconnect = hw1-vapp033:2181 | file --dir = / tmp / myfile --name = all_sdrs” 我希望在kafka主题“rm-sdrs”上看到一个新的消费者,但在Zookeeper上看不到任何内... -
0 votesanswersviews
如何将springxd源mqtt注册到mqtt broker
我用spring-Xd创建了一些流,例如 - stream create mqtttestfile --definition "mqtt --url='tcp://localhost:1883' --topics='helloTopic' | file" --deploy 创建并部署了新的流'mqtttestfile' . 我还检查了localhost:9393 / admi... -
1 votesanswersviews
Spring XD jdbc(源码) - > jdbc(sink)
我正在尝试配置如下的流(直接从jdbc源管道到jdbc接收器) xd> stream create test2 --definition“output:jdbc --split = true --username = test --password = test --driverClassName = com.mysql.jdbc.Driver --url = jdbc:mysql:// ... -
5 votesanswersviews
如何从cassandra表中流式传输数据?
我想从一个实时更新的cassandra表中流式传输数据 . 是的,它是一个数据库但是有办法做到这一点吗?如果是这样,保留偏移或我可以使用哪些CQL查询? -
1 votesanswersviews
Spring Integration和Kafka Consumer:在成功获取记录后立即停止消息驱动通道适配器
我正在使用以下内容: spring-integration-kafka 2.1.0.RELEASE kafka-clients 0.10.0.1 Kafka 0.10.x.x. spring-xd-1.3.1.RELEASE 我为SpringXD创建了自定义的Kafka-source模块 . 我设置了我的消费者逻辑和我的 message-driven-channel-adapt...