我想在cassandra中编写一个从keyspace读取数据并写入队列的IntegrationFlow。根据我到目前为止所做的研究，我无法找到用于从cassandra读取行的InboundChannelAdapter。我在GitHub上找到了一个名为的项目，但我没有找到InboundChannelAdapter。
对于我的场景来说，编写自己的InboundChannelAdapter是唯一的
浏览 1提问于2018-02-14得票数 0
回答已采纳
我正在尝试在spring集成中实现一个自定义的入站通道适配器，以使用来自的消息。基于spring集成示例，我发现我需要创建一个实现MessageSource接口的类，并实现从kafka返回消费消息的receive()方法。但是基于，KafkaStream中的消息迭代器是由BlockingQueue支持的。因此，如果队列中没有消息，线程将被阻塞。那么，实现接收()方法的最佳方式是什么，因为该方法可能会
浏览 1提问于2013-02-01得票数 0
回答已采纳
我在我的网络流量应用程序中使用Spring和。当我使用test容器与docker进行集成测试时，我遇到了问题，Spring没有在我的测试中注入cassandra存储库的实现，但是它总是注入Mockito模拟对象。对于测试，我有两种测试，即unitTest和integrationTest，并进行适当的配置测试和集成。
我的基本集成测试类，它使用docker作为真正的c
浏览 11提问于2022-03-21得票数 0
如何使用Java Config或Spring DSL进行此配置？
浏览 31提问于2021-08-31得票数 1
回答已采纳
我正在用Cassandra存储库建立一个Spring应用程序。但是，由于应用程序停止了编译，Maven已经变成了流氓。 Spring数据卡桑德拉没有得到正确的处理。"org.springframework.cassandra.core.mapping“中的所有内容都不存在于本地。而且看起来我还有其他的软件包"...cassandra.core“是可以的。Cassandra映射类，如@Table、@
浏览 2提问于2018-01-10得票数 1
回答已采纳
大家好，我正在考虑将我的cassandra api层迁移到nodejs或java，我试过一点，但我仍然不确定哪种技术对可伸缩性和维护性更好，cassandra的java client for cassandra似乎工作起来很愉快，有谁有使用这两种技术的经验吗？
浏览 3提问于2014-04-29得票数 0
4回答
在我的SpringBoot1.5.1应用程序中，我将为Cassandra相关逻辑编写单元/集成测试。我增加了对Maven的依赖： <groupId>org.springframework.boot</groupId></d
浏览 4提问于2017-02-13得票数 8
回答已采纳
我是新的Cassandra (甚至不是编写查询的想法)，我想将Cassandra与spring rest应用程序集成。我经历了许多链接，但我不能决定哪一个是更好的spring-data-Cassandra、Kundera或Easy-Cassandra。请告诉我彼此的优点或缺点，以便我可以在应用程序中选择和使用它们。
有没有可能使用spring-data-Cassandra<
浏览 1提问于2014-11-27得票数 0
我有一些关于Spring Integration和控制总线的问题。我需要在InboundChannelAdapter上关闭自动启动功能。下面是我的全部代码： package com.example.springintegrationdemo;
import org.springframework.i
浏览 12提问于2020-07-29得票数 1
回答已采纳
2回答
持久化工作流
、、
我试图用Spring集成实现以下工作流：
@InboundChannelAdapter(value = "consulHttp", poller = @Poller(maxMessagesPerPoll = "1", fixedDelay但是现在，我不想将对象写入文件中，而是将其存储在带有
浏览 4提问于2015-12-19得票数 3
我使用的是spring cloud数据流。@Beanpublic Supplier预期的性能是在kafka宕机后停止数据轮询。 有没有可能实现这一点的方法？
浏览 31提问于2020-12-21得票数 0
我正在从事基于注解的Spring集成项目。我试图用轮询器编写@ServiceActivator，但问题是消息轮询恰好发生了3次，然后就停止了。这里的问题可能是什么？同样的轮询在@InboundChannelAdapter上也能很好地工作，但我想知道为什么它不能在ServiceActivator上工作。
浏览 96提问于2019-12-25得票数 0
回答已采纳
我正在尝试使用spring cloud stream在kafka上发送和接收消息。这方面的示例使用了一个使用时间戳作为消息的简单示例。当我在上遇到这个拦截器时，我正试图更深入地了解现实世界的应用程序我试着这样使用它：
@InboundChannelAdapter但是“带有@InboundChannelAdapter注解的方法不能接受任何参数”。那么你应该如何使用它呢？我知
浏览 0提问于2017-07-27得票数 0
我需要将一些遗留代码移植到基于spring集成的应用程序中。我决定通过@InboundChannelAdapter注释配置入站通道适配器，该注释按预期工作。问题是，当调用入站通道适配器的start()和stop()方法时，我需要执行一些代码。 //my code to be executed &
浏览 2提问于2014-12-01得票数 2
回答已采纳
对于文件读取消息源，带有注释的入站适配器和转换器配置如下@InboundChannelAdapter(autoStartup = "false", value = "incomingchannelpublic JobLaunchRequest toRequest(Message<File> message) throws Exception {
现在，我想将转换器更改为引用出站网关的应答通道在注释配置之后，我将不得不更改转换器输入通道，以引用新目录通道，即消息网关的</e
浏览 4提问于2020-04-22得票数 0
回答已采纳
我为我的spring引导应用程序开发了集成测试，它与Cassandra一起工作。我使用CassandraTemplate与卡桑德拉通信。对于数据库src/test/resources/application.properties，我有以下配置
spring.data.cassandra.contact-points=cassandra-hostspring.data.cassandra.port=9042
浏览 0提问于2019-08-16得票数 6
回答已采纳
我在春季云数据流中工作，在那里我有一个场景，比如从数据库中读取数据，并使用@In量InboundChannelAdapter将数据发送到kafka主题->if列表中有我不会投票的数据public void initList()
浏览 4提问于2020-12-11得票数 0
2回答
我试图使用spring数据(最好是jpa)连接cassandra数据库。我找不到任何克拉拉的例子怎么做，没有指导。我为MongoDB和Neo4j找到了一些，但卡桑德拉却没有。在春季的邮件页面上，提到了coassandra项目，但没有提供任何示例或指南。有人能帮忙吗？
浏览 1提问于2014-09-11得票数 0
回答已采纳
我读了Spring Cloud Stream Binder的文档，但只发现如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。因此，我不知道是否可以继续使用像@Input、@Ouptut这样的注释来定义单个处理器，在这一点上我非常困惑，因为库表明这些注释已被弃用，但我找不到示例或文档来定义一个简单的生产者来向特定主题发送信息。文档链接：https://docs.spring.io/spring-cloud-stream-
浏览 30提问于2021-01-22得票数 2
我们在一个项目中使用了spring batch和集成 我们使用spring集成来轮询和监视目录；当一个文件进入目录时，我们记录并移动到另一个目录。这就是我们监控的方式 @Bean } 一旦文件被轮询，我们将使用下面的function..we
浏览 16提问于2021-04-22得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号