-
3 votesanswersviews
由于'requestMappingHandlerMapping'初始化失败,Spring启动应用程序未运行
它是一个早期运行的spring boot 2.0.0应用程序,但是在我添加了spring-cloud-stream的依赖项之后,这个错误就开始了 . 我尝试删除了spring-fox依赖项,但它只删除了嵌套异常 . 删除spring-fox依赖后的完整错误: ConfigServletWebServerApplicationContext:在上下文初始化期间遇到异常 - 取消刷新尝试:org.s... -
0 votesanswersviews
如何忽略maxAttempts并向DLQ发送消息?
我正在使用RabbitMQ . 消费者-api正在使用spring-cloud-steam . 目前,当maxAttempts为3时,如果消费者未能处理该消息,则它将再次排队 . 这将发生3次 . 如果第3次也是消息失败,则它将被发送到DLX-> DLQ . 如下图所示 现在我想跳过重试,如果在侦听器端发生了一些specificException . 如何跳过此重试并直接将消息发送到DLX-... -
0 votesanswersviews
Spring Cloud Stream Kafka Producer消息
我想用spring boot设置一个spring-cloud-stream-kafka制作人 . 生产环境 者正在工作,我可以使用来自kafka代理的消息,但消息还包含一些 Headers 信息,如下所示: contentType "text/plain"originalContentType "application/json;charset=UTF-... -
1 votesanswersviews
Kafka制作人JSON序列化
我正在尝试使用Spring Cloud Stream与Kafka集成 . 正在编写的消息是Java POJO,虽然它按预期工作(消息正在写入主题,我可以使用消费者应用程序读取),但是在消息的开头添加了一些未知的字符尝试集成Kafka Connect以接收来自主题的消息时出现问题 . 使用默认设置,这是推送到Kafka的消息: contentType "text/plain&qu... -
0 votesanswersviews
如何使用2.0.0.M4版本配置Spring Cloud Turbine Stream和Spring Boot Actuator?
我有以下配置: @EnableTurbineStream @EnableDiscoveryClient @SpringBootApplication public class SquintTurbineServerApplication { public static void main(final String... args) { SpringApplication.run... -
0 votesanswersviews
Kafka消息被重新处理
我们有一个微服务,使用spring-boot和spring-cloud-stream生成和使用来自Kafka的消息 .版本:spring-boot:1.5.8.RELEASEspring-cloud-stream:Ditmars.RELEASEKafka服务器:kafka_2.11-1.0.0 EDIT: 我们正在使用包含3个Kafka节点的StatefulSets群集和3个Zookeeper节点... -
0 votesanswersviews
如何使用spring boot和spring cloud stream在kafka制作者上设置avro内容类型
尝试使用spring boot,spring cloud stream schema registry,kafka binder,与avro消息 生产环境 者,kafka和avro消费者一起构建工作示例 . 尝试使用消息时出错: ERROR 7059 --- [afka-listener-1] oscsbkKafkaMessageChannelBinder:无法使用contentType [app... -
0 votesanswersviews
使用Spring Kafka Consumer时,Spring Cloud Stream Producer会添加“垃圾”字符
我们的微服务使用JDK 8,带有Spring Boot 1.5.2.RELEASE的Spring Cloud Stream API,用于在Kafka Queue上生成消息 . 对于Consumer API,我们使用Spring Kafka 1.1.2.RELEASE,特别是 @KafkaListener . 消息类型是应用程序json 我们注意到消费者在"contentType&quo... -
2 votesanswersviews
spring-cloud-stream消息转换异常
在将我们的某个服务升级到 spring-cloud-stream 2.0.0.RC3时,我们在尝试使用由使用旧版本的 spring-cloud-stream - Ditmars.RELEASE的服务生成的消息时遇到异常: ERROR 31241 --- [container-4-C-1] osintegration.handler.LoggingHandler:org.springfra... -
0 votesanswersviews
Spring Cloud Stream邮件正文中的嵌入式标头
我使用Spring Cloud Stream 1.3.2.RELEASE向Kafka发布String消息 . 当我使用命令行Kafka使用者或Spring Kafka @KafkaListener 使用消息时,contentType头始终附加到消息正文 . Question : 有没有办法摆脱嵌入式标头? Spring Cloud Stream as producer private vo... -
1 votesanswersviews
非Spring Cloud Stream(SCS) 生产环境 者向SCS消费者发送JSON消息
我有一个非SCS 生产环境 者(使用Spring-Kafka的应用程序)尝试将一个json序列化对象发送到SCS使用者订阅的主题 . 关于这个主题的信息是 - {“message”:“hello world2”,“mobileNumber”:“111111”} SCS消费者具有以下配置 . spring.cloud.stream.bindings.input.content-type = appl... -
0 votesanswersviews
使用原始标头发布null / tombstone消息
我正在构建一个Spring Cloud Stream Kafka处理器应用程序,它将使用String键消耗原始数据,有时使用Kafka主题的空载荷 . 我想向另一个主题生成一个String键和null有效负载(在Kafka中称为墓碑) . 为了在消息上使用原始标头,我需要输出 byte[] ,但如果我将 KafkaNull.INSTANCE 编码为 byte[] ,它将逐字输出对象哈希码的字符串 ... -
2 votesanswersviews
带有headerMode = raw的JSON MessageHeaders
我有一个Spring Cloud Stream(SCS)Kafka 生产环境 应用程序配置了Sleuth用于跟踪 . 我正在尝试发布需要通过以下方式消费的弹出消息“GenericMessage”(即MessageHeaders有效负载): SCS消费者(谁应该继续自动添加到MessageHeaders的跟踪) 非SCS / Java消费者,他们应该跳过MessageHeaders并处理有效... -
6 votesanswersviews
如何使用Spring Cloud Stream Kafka和每服务数据库实现微服务事件驱动架构
我正在尝试实现事件驱动的体系结构来处理分布式事务 . 每个服务都有自己的数据库,并使用Kafka发送消息以通知其他微服务有关操作 . 一个例子: Order service -------> | Kafka |------->Payment Service | | Orders MariaDB D... -
1 votesanswersviews
正确管理Spring Cloud Stream Kafka中的DLQ
我想使用kafka在Spring Cloud Stream中管理DLQ . application.yaml server: port: 8091 eureka: client: serviceUrl: defaultZone: http://IP:8761/eureka spring: application: na... -
2 votesanswersviews
spring-cloud-stream kafka错误处理
我查看了spring-cloud-stream 1.0.0.RELEASE的文档,但似乎找不到任何有关错误处理的文档 . 基于对kafka 0.9的观察,如果我的消费者抛出RuntimeException,我会看到3次重试 . 在3次重试之后,我在日志中看到了这一点: 2016-05-17 09:35:59.216 ERROR 8983 --- [ kafka-binder-] o.s.i.k.... -
2 votesanswersviews
如何使用Rabbit绑定创建带有Transaction和DLQ的处理器?
我刚刚开始学习Spring Cloud Streams和Dataflow,我想知道一个重要的用例 . 我创建了示例处理器Multiplier,它接收消息并重新发送5次以输出 . @EnableBinding(Processor.class) public class MultiplierProcessor { @Autowired private Source source; ... -
1 votesanswersviews
字符串 Cloud 流 - 如果启用了重试,如何在不重新签名的情况下强制删除邮件?
我们正在使用Spring Cloud Stream,并且我们在消费者中使用maxAttempts> 1启用了重试 . 有没有办法迫使消息立即发送到DLQ,即绕过例如重新排队的消息 . 处理邮件时在使用者侦听器中抛出特殊异常? -
0 votesanswersviews
达到消费者maxAttempts后会发生什么?
使用以下配置和方案,达到maxAttempts时会发生什么? 具有Kafka绑定的Spring Cloud Stream和以下属性: spring.cloud.stream.bindings.input.consumer.maxAttempts = 3 spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOffset = ... -
1 votesanswersviews
在Spring Cloud 流中抛出异常会得到ClassCastException
我使用的是Spring Cloud Stream 2.0.0 RC3 . 如果我在消费者中抛出异常,我会得到 ClassCastException . 我很困惑,为什么抛出异常会导致 ClassCastException . 这是Spring Cloud Stream中的预期行为吗?如果消费者不能消费消息而不是抛出异常,那么最佳做法是什么? (DLQ?) 码: @StreamListener(... -
1 votesanswersviews
避免向DLQ / DLX发送消息
我们的应用程序正在使用org.springframework.cloud,spring-cloud-starter-stream-rabbit框架,我们试图避免向DLQ发送特定消息并重试它们,这种行为应该以某种方式动态,因为对于默认消息,重试和DLQ应该工作 . 根据这个文件: Putting it All Together 这个有用的帖子: DLX in rabbitmq and spring-... -
0 votesanswersviews
Spring Cloud 流产生并消耗相同的主题
我有一个使用Spring Boot和Spring Cloud Stream的服务 . 此服务会生成某个主题,并且也会使用此主题 . 当我第一次启动该服务并且Kafka中不存在该主题时,抛出以下异常: java.lang.IllegalStateException:预期分区的数量为:100,但在org.springframework.cloud.stream.binder.kafka.provis... -
1 votesanswersviews
spring-cloud-stream kafka json内容类型
我正在尝试使用spring-cloud-stream 1.0.0.M4和各种 Binders . 我不是在 生产环境 者和消费者之间共享我的数据传输对象(谁这样做?)所以我遇到了为绑定包含内容类型配置的需要 . 生产环境 者配置: spring: cloud: stream: bindings: customer-save: "customer-... -
4 votesanswersviews
spring-cloud-stream kafka消费者并发
使用spring-cloud-stream的kafka Binders ,如何配置并发消息使用者(在单个消费者jvm中)?如果我理解正确,使用kafka时并发消息消耗需要分区,但s-c-s docs表示要使用分区,您需要通过partitionKeyExpression或partitionKeyExtractorClass在生成器中指定分区选择 . Kafka docs提到了循环分区 . s-c-... -
5 votesanswersviews
Spring Cloud Stream和Kafka集成错误处理
我正在尝试使用Spring Cloud Stream和Kafka集成创建Spring Boot应用程序 . 我在Kafka中创建了一个带有1个分区的示例主题,并根据此处给出的指示从Spring Boot应用程序发布了该主题 http://docs.spring.io/spring-cloud-stream/docs/1.0.2.RELEASE/reference/htmlsingle/index.... -
0 votesanswersviews
Spring Cloud 流Kafka Reactive流分区分配
Spring Cloud 流如何将多个Kafka分区分配给属于同一个用户组的反应流? 我注意到,如果我使用普通的非反应流监听器,则每个线程都会分配给一个分区,具体取决于消费者并发配置 . 然而,在流(Flux输入)的情况下,我没有注意到任何这样的并行行为 . 似乎只定义了一个流来处理来自所有分区的消息 . 我的期望是为每个Kafka主题分区提供单独的流,即使在由不同线程备份的同一节点上也是如此 .... -
1 votesanswersviews
Spring Cloud Stream Kafka是否支持嵌入式标头?
根据这个主题:Kafka Spring Integration: Headers not coming for kafka consumer - 这对Kafka没有头文件支持 但documentation说: spring.cloud.stream.kafka.binder.headers将由 Binders 传输的自定义标头列表 . 默认值:空 . 我 can't 使用spring-clo... -
1 votesanswersviews
如何配置Spring Cloud 流(kafka)以使用protobuf作为序列化
我使用Spring Cloud 流(kafka)在 生产环境 者和消费者微服务之间交换消息 . 它与本机java序列化交换数据 . 根据Spring Cloud 文档,它支持JSON,AVRO序列化 . 有没有人在spring Cloud 流中尝试过protobuf序列化(消息转换器) ----------------后来添加 我写了这个MessageConverter public class ... -
0 votesanswersviews
在Spring Cloud Stream 2.0中发送消息时,@ InboundChannelAdapter与MessageChannel的区别
我尝试了两种方法在Spring Cloud Stream 2.0 RC3中发送消息 . 一个使用 MessageChannel 发送消息 . public interface Chan { @Output MessageChannel sender(); } @SpringBootApplication @EnableBinding(Chan.class) public clas... -
0 votesanswersviews
Spring Cloud Stream IntegrationFlow with Rabbitmq messaging,消费者将ASCII数字作为消息有效负载
我正在使用spring cloud stream进行消息传递 . 在消费者部分,我使用IntegrationFlow来侦听队列 . 它正在监听并打印来自制作人的信息 . 但格式不同,这就是我现在面临的问题 . 生产环境 者的内容类型是application / json和显示ASCII数字的IntegrationFLow消息有效负载 . 代码是为消费者编写的,如下所示 @EnableBindin...