当前分类:spring-cloud-stream

avro - 尝试在 Spring Cloud Stream 中解码 Avro 消息时出现无法识别的 header 字节错误

google-cloud-platform - 无法从 GCP pubsub 读取

spring-kafka - 不能在测试中多次使用 @KafkaListener

apache-kafka-streams - Spring Cloud Kafka Streams Binder 运行状况为 "UNKNOWN"

apache-kafka-streams - 根据部分数据属性更新KTable

apache-kafka - 如何更新创建主题的复制因子?

kotlin - Spring Cloud Kafka限制单位时间消息消耗

spring-cloud - 使用 Spring Cloud Bus Kafka 的多个实例

kotlin - 如何使用 spring-cloud-function 消费 Kafka 事件,但有时只产生

java - 当 Spring Cloud Stream 响应式消费者遇到异常时,为什么我会收到 onComplete 信号?

java - 如何在 Kafka Streams 应用程序中处理偏移提交期间的超时异常

java - 在 Spring Cloud Stream 中使用 PollableMessageSource 输入时如何使用 avro native 解码器?

spring - EnableBinding 类型已弃用,StreamListener 类型已弃用 - Spring Cloud Stream

spring-kafka - Spring Cloud Stream - kafka - 空确认 header

使用 Spring Cloud Stream 处理 Avro 反序列化异常

java - 使用 Spring Cloud Stream Kafka Binder 时 Kafka Producer 中的错误处理

spring-cloud-stream - Spring云流消息传递。消息为空

spring-cloud-stream - Spring云数据流: complex parallel processors scenario?

java - 消费批处理后获取 java.lang.ClassCastException : [B cannot be cast to org. springframework.messaging.Message 异常

spring-cloud-stream - StreamBridge 的替代方案

热门标签: