spring-cloud-stream 第8页 - IT屋-程序员软件开发技术分享社区

Spring Cloud Stream动态频道

我正在使用Spring Cloud Stream，并想以编程方式创建和绑定频道.我的用例是，在应用程序启动期间，我会收到要订阅的Kafka主题的动态列表.然后如何为每个主题创建频道? 解决方案我最近遇到了类似的情况，下面是我动态创建SubscriberChannel的示例. ConsumerProperties ConsumerProperties =新的ConsumerProper ..

发布时间：2021-04-08 18:50:08 spring-boot apache-kafka spring-cloud-stream 其他开发

Spring Cloud Stream Kafka暂停/恢复活页夹

我们正在使用Spring Cloude流 2.0 &Kafka作为消息代理. 对于目标系统(DB或第三方API)无法使用的情况，我们已实现了一个断路器，该断路器可停止应用程序上下文，如此处所示:绑定可视化和控件是否有可能通过代码控制活页夹的生命周期，是否意味着在目标服务器关闭的情况下暂停活页夹，以及在启动时恢复 resume ? 解决方案对不起，我没看懂你的问题. 您可以 ..

发布时间：2021-04-08 18:45:34 java apache-kafka spring-cloud-stream spring-kafka circuit-breaker Java开发

Kubernetes上的Spring Cloud Dataflow部署时出现错误

我正在开发Spring Cloud Dataflow Stream应用程序.我能够使用Cloud Foundry中运行的船长来运行Spring云数据流服务器.现在，即使我在部署中的环境配置中明确给出了用户名，我仍试图与在kubernetes集群中运行的船长运行相同的代码，并在部署时遇到错误. 原因:io.fabric8.kubernetes.client.KubernetesClientEx ..

发布时间：2021-02-15 20:40:31 spring-cloud-stream kubernetes-ingress spring-cloud-dataflow spring-cloud-kubernetes 其他开发

使用kafka流绑定器测试Spring云流:使用TopologyTestDriver，我收到“类不在受信任包中"的错误.

我有一个使用kafka stream活页夹的简单流处理器(不是消费者/生产者). @Bean fun processFoo():Function, KStream> { return Function { input-> input.map { key, value -> ..

发布时间：2021-02-15 19:46:36 unit-testing kotlin spring-cloud-stream 其他开发

杰克逊无法反序列化(Spring Cloud Stream Kafka)

我正在尝试从kafka中读取json消息，但出现了一个异常，该异常表示Jackson无法将json反序列化为POJO. json就像{"code":"500","count":22,"from":1528343820000,"to":1528343880000}，它是kafka流的输出. POJO声明json的所有属性，并且与生成JSON消息的POJO完全相同.所以我不知道为什么会这样 ..

发布时间：2021-02-09 20:13:56 jackson spring-cloud-stream 其他开发

如何配置Spring Cloud StreamBridge来生产Avro？

因此，我尝试使用StreamBridge将消息动态发送到不同的主题。如果我的输出是 Message ，但不是消息代码示例： @StreamListener（Sink.INPUT）公共无效过程（@Payload GenericRecord messageValue， @Header（KafkaHeaders.RECEIVED_MESSAG ..

发布时间：2020-10-27 01:43:43 spring dynamic spring-cloud spring-cloud-stream confluent-platform 其他开发

Spring Cloud Dataflow有什么好处？

根据我所看到的，在Spring Cloud Dataflow（SCDF）中创建流将部署基础应用程序，绑定通信服务（如RabbitMQ），设置Spring Cloud Stream环境变量并启动应用程序。同时，我一直在使用Spring Cloud Dataflow遇到一些缺点： SCDF服务器是PCF上的内存猪（我的流只有6个应用程序，但服务器大约需要10GB）在应用程序命名，内存 ..

发布时间：2020-10-03 00:38:34 cloudfoundry spring-cloud-stream spring-cloud-dataflow 其他开发

在获取数据Spring-Cloud-Stream Kafka Azure事件中心时出现意外错误代码13-

自12月18日以来，此问题突然弹出，一切正常，找不到任何线索，这个异常情况在经过6个月的正常工作后突然不断出现. 我无法在本地独立环境中进行复制，但是它出现在具有微服务的docker映像中，其中之一与 Azure even hub 进行通信. > 我已经搜索并找到了发布.在这篇文章中，我也遇到了同样的问题，但是找不到任何解决方法或线索，所以我发布了这个问题. 请参考下面的堆栈跟踪: ..

发布时间：2020-09-17 03:54:51 azure spring-boot apache-kafka spring-cloud-stream azure-eventhub 其他开发

使用Spring Cloud Stream处理一次是否可以获得准确的处理?

当前，我正在使用具有几乎默认配置的SCS在微服务之间发送和接收消息. 不知何故我已经读过了 https://www.confluent.io/blog/enabling-exactly-kafka-流并想知道我们是否只是通过Spring启动应用程序中的属性在其中放置值为"exactly-once"的"processing.guarantee"属性，是否可行? 解决方案在您的问题 ..

发布时间：2020-09-03 19:25:06 spring-boot apache-kafka-streams spring-cloud-stream spring-kafka 其他开发

Spring @StreamListener进程(KStream<?，?>流)分区

我的流处理器中有一个包含多个分区的主题，我只是想从一个分区中进行流式处理，因此无法弄清楚如何配置它 spring.cloud.stream.kafka.streams.bindings.input.consumer.application-id=s-processor spring.cloud.stream.bindings.input.destination=uinput spring.c ..

发布时间：2020-09-03 19:23:38 apache-kafka-streams spring-cloud-stream 其他开发

如何在spring-cloud-stream中的kafka进程拓扑中使用交互式查询?

是否可以在Spring Cloud Stream中使用具有@EnableBinding批注的类或在具有@StreamListener的方法中使用交互式查询(InteractiveQueryService)?我尝试实例化提供的我的@StreamListener方法正在监听一堆KTables和KStreams，并且在过程拓扑(例如过滤)期间，我必须检查KStream的键是否已存在于特定的KTable中 ..

发布时间：2020-09-03 19:21:02 java apache-kafka apache-kafka-streams spring-cloud-stream Java开发

根据部分数据属性更新KTable

我正在尝试使用对象的部分数据更新KTable. 例如.用户对象是 {"id":1, "name":"Joe", "age":28} 该对象将流式传输到主题中，并按关键字分组到KTable中. 现在，用户对象按{"id":1, "age":33}部分更新，并流式传输到表中.但是更新的表如下所示{"id":1, "name":null, "age":28}. 预期的输出是{"id":1, "name" ..

发布时间：2020-09-03 19:19:30 apache-kafka-streams spring-kafka spring-cloud-stream 其他开发

与Kafka Spring Cloud Stream多个@EnableBinding

我正在尝试设置一个侦听Kafka的Spring Boot应用程序. 我正在使用Kafka Streams Binder. 一个简单的@EnableBinding @EnableBinding(StreamExample.StreamProcessor.class) public class StreamExample { @StreamListener(StreamPr ..

发布时间：2020-09-03 19:07:47 spring-boot apache-kafka apache-kafka-streams spring-cloud-stream 其他开发

如果在处理步骤中发生故障，如何使Spring云流Kafka流绑定程序重试处理消息?

我正在使用Spring Cloud Stream开发Kafka Streams.在消息处理应用程序中，可能会产生错误.因此，不应再次提交并重试该消息. 我的申请方法- @Bean public Function, KStream> process() { return (input) -> { KStream ..

发布时间：2020-07-25 19:25:09 java apache-kafka-streams spring-cloud-stream event-driven-design spring-cloud-stream-binder-kafka Java开发

num.stream.threads创建空闲线程

我有一个带有两个主题的spring boot kafka流应用程序，考虑主题A和B.主题A有16个分区，主题B有1个分区.考虑将应用程序部署在1个实例中，该实例的num.stream.threads = 16. 我运行kafka-consumer-groups.bat命令来检查如何将线程分配给组中的分区，得到以下输出.主题A和B分配了16个线程，其中主题B中的14个线程处于空闲状态. kaf ..

发布时间：2020-07-25 19:25:04 apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka spring-boot-cloud-streams 其他开发

引起原因:com.fasterxml.jackson.databind.exc.InvalidDefinitionException:未为类org.springframework.core.convert.support.Defa找到序列化程序.

我正在研究Spring Cloud Stream Apache Kafka示例.我正在开发引用以下代码的代码: https://www.youtube.com/watch?v= YPDzcmqwCNo . org.springframework.messaging.MessageDeliveryException: failed to send Message to channel 'pvo ..

发布时间：2020-07-25 19:25:02 spring-cloud-stream spring-cloud-stream-binder-kafka 其他开发

spring-cloud-stream相关内容