spring-integration相关内容

spring集成中将json转换为对象数组

我们以 json 格式从服务(http 出站网关)返回一组对象,我们需要将其序列化回一组对象/POJOS.首先,我们尝试通过将 XML 配置设置为 来简单地序列化没有任何数组列表的 POJO 并且让转换器和 http 出站网关返回相同的对象.但是,在将其转换为“ApplicationTestDomain"POJO 数组后,我们收到了堆栈跟踪中提到的错误,其中特别提到了 “找不到能够从类型 ..
发布时间:2021-11-18 00:21:20 其他开发

spring集成中将json转换为对象数组

我们以 json 格式从服务(http 出站网关)返回一组对象,我们需要将其序列化回一组对象/POJOS.首先,我们尝试通过将 XML 配置设置为 来简单地序列化没有任何数组列表的 POJO 并且让转换器和 http 出站网关返回相同的对象.但是,在将其转换为“ApplicationTestDomain"POJO 数组后,我们收到了堆栈跟踪中提到的错误,其中特别提到了 “找不到能够从类型 ..
发布时间:2021-11-18 00:18:14 其他开发

从 Kafka 消费失败的迭代器处于失败状态

我在使用来自 kafka 的消息时遇到异常. org.springframework.messaging.MessagingException:从 Kafka 消费失败;嵌套异常是 java.util.concurrent.ExecutionException: java.lang.IllegalStateException: Iterator is in failed state 我在应用程 ..
发布时间:2021-11-14 23:57:49 其他开发

maprsteam 与 spring 集成 java 客户端

我正在寻找将 ma​​prstream 与 spring 集成一起使用的解决方案.我可以创建流和主题,还可以使用流:主题组合使用/发布消息.通过参考链接使用了Kafka客户端::> 但是努力使用 Spring 集成来消费/发布消息,并且看不到任何解释相同的示例程序.有人可以帮我解决这个问题吗? 解决方案 spring-integration-kafka 2.0(通过 spring-kaf ..
发布时间:2021-11-12 03:22:24 其他开发

maprsteam 与 spring 集成 java 客户端

我正在寻找将 ma​​prstream 与 spring 集成一起使用的解决方案.我可以创建流和主题,还可以使用流:主题组合使用/发布消息.通过参考链接使用了Kafka客户端::> 但是努力使用 Spring 集成来消费/发布消息,并且看不到任何解释相同的示例程序.有人可以帮我解决这个问题吗? 解决方案 spring-integration-kafka 2.0(通过 spring-kaf ..
发布时间:2021-11-12 03:20:25 其他开发

我需要当前易于遵循的说明来从 XML 配置 spring 集成 kafka

spring 集成 kafka 模型已经发生了足够的变化,因为它已经被处理和简化,现有的演示、手册和说明不再起作用.目前官方的demo都是围绕注解构建的,虽然很酷,但基本上不可读,不适合我的架构,作业与java代码分开部署和管理. 是否有当前 (2019) 教程,用于在 XML 中配置 spring 集成生产者和消费者? 作为参考,这里是我 POM 的摘录,详细说明了我正在使用的版本: ..
发布时间:2021-11-12 03:16:58 其他开发

使用来自 MQ 的消息并在 Spring JMS 中合并

我使用 spring + MQ + Websphere 应用服务器. 我想异步使用来自 MQ 的消息并将这些消息组合起来,以便在每次提交中轻松将 N 个实体持久化到数据库中.(没有强调我的目标 Oracle 数据库太多提交) 我使用 DefaultMessageListenerContainer 并使 onMessage 方法同步以添加消息(直到批量大小),并创建线程以等待条件满足(时 ..
发布时间:2021-11-12 03:13:57 其他开发

我需要当前易于遵循的说明来从 XML 配置 spring 集成 kafka

spring 集成 kafka 模型已经发生了足够的变化,因为它已经被处理和简化,现有的演示、手册和说明不再起作用.目前官方的demo都是围绕注解构建的,虽然很酷,但基本上不可读,不适合我的架构,作业与java代码分开部署和管理. 是否有当前 (2019) 教程,用于在 XML 中配置 spring 集成生产者和消费者? 作为参考,这里是我 POM 的摘录,详细说明了我正在使用的版本: ..
发布时间:2021-11-12 03:13:04 其他开发

Spring-Kafka 集成 1.0.0.RELEASE 问题与生产者

我无法使用 Spring Kafka 集成发布消息,但我的 Kafka Java 客户端工作正常. Java 代码运行在 Windows 上,Kafka 运行在 Linux 机器上. KafkaProducerContextkafkaProducerContext = new KafkaProducerContext();ProducerMetadataproducerMetadata ..
发布时间:2021-11-12 03:04:10 其他开发

spring kafka:同一主题上的不同 json 有效负载

我需要在不使用父类的情况下在同一个 Kafka Topic(例如,Foo、Bar、Car ...)上发送不同的 JSON 负载 基于 spring kafka 文档,我可以在类级别使用 @KafkaListener 并在方法级别指定 @KafkaHandler ( doc ) @KafkaListener(topics = "myTopic")静态类 MultiListenerBean { ..
发布时间:2021-11-12 03:01:15 其他开发

Spring Integration Kafka适配器不产生消息

我为此苦苦挣扎了好几天. 我在 Spring-boot 容器下为 kafka 使用 SI 适配器. 我已经在我的机器上配置了zookeeper和kafka.我还创建了控制台生产者和消费者对其进行了测试,一切正常(我设法生成了控制台消息并让控制台消费者使用它们). 我现在尝试通过 Spring 集成 kafka 出站适配器生成消息,但控制台使用者不会使用该消息 SI/Spri ..
发布时间:2021-11-12 02:48:45 其他开发

Spring Integration Kafka Consumer Listener未接收消息

根据此处提供的文档,我正在尝试使用 POC 将消息发送到 相同的文档,下面是我编写配置的方式. @Configuration公共类 KafkaConsumerConfig {public static final String TEST_TOPIC_ID =“记录流";@Value("${kafka.topic:" + TEST_TOPIC_ID + "}")私人字符串主题;@Value("${ ..
发布时间:2021-11-12 02:16:39 其他开发

带有 spring-kafka 的 Kafka 死信队列(DLQ)

在使用 spring-kafka 2.1.x 的 Spring Boot 2.0 应用程序中实现 死信队列 (DLQ) 概念的最佳方法是什么,以便 处理所有消息失败@KafkaListener 某些 bean 的方法发送到某些预定义的 Kafka DLQ 主题并且不会丢失单个消息? 因此消耗的 Kafka 记录是: 已成功处理, 处理失败并发送到DLQ主题, 处理失败,未发送到DL ..
发布时间:2021-11-12 02:07:14 其他开发