腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(2621)
视频
沙龙
1
回答
Spring
Cloud
Stream
-
Kafka
活页夹
apache-kafka
、
spring-cloud
、
spring-cloud-stream
这两个
活页夹
有什么区别?他们的行为或多或少都是一样的--比如生产、加工和消费。https://
cloud
.
spring
.io/
spring
-
cloud
-static/
spring
-
cloud
-
stream
-binder-
kafka
/3.0.0.RELEASE/reference/html/
spring
-
cloud
-<em
浏览 20
提问于2020-07-19
得票数 0
回答已采纳
1
回答
使用多个绑定器时,无法使用@StreamRetryTemplate创建自定义RetryTemplate
spring-cloud-stream
我正在使用
spring
cloud
stream
和多个
活页夹
。我尝试使用@StreamRetryTemplate创建自定义RetryTemplate。当我尝试使用单个
活页夹
时,它工作正常。retryTemplate.setRetryPolicy(simple);} application.yml: server:
spring
:
stream
:
浏览 37
提问于2019-04-30
得票数 0
1
回答
Spring
cloud
Kafka
streams
活页夹
健康状况“未知”
apache-kafka-streams
、
spring-cloud-stream
我们使用2.1.3版本的
spring
cloud
stream
kafka
streams - <dependency> <artifactId>
spring
-
cloud
-
stream
-binder-
kafka
-streams</
浏览 12
提问于2019-10-11
得票数 1
1
回答
当zookeeper关闭时,
Spring
云流不会抛出异常
apache-kafka
、
apache-zookeeper
、
spring-cloud-stream
我正在使用
kafka
包附带的zookeeper的
kafka
。我还使用了
spring
cloud
stream
和
kafka
活页夹
。我想看看如果zookeeper关闭会发生什么,而
kafka
代理正在运行。我通过
spring
cloud
stream
源给
kafka
主题发了一些东西。令我惊讶的是,
spring
cloud
stream
并
浏览 0
提问于2017-08-11
得票数 1
1
回答
承认一条信息不应该让它被重新传递给卡夫卡消费者吗?
java
、
apache-kafka
、
ibm-mq
、
spring-cloud-stream
我正在运行
Stream
应用程序,在该应用程序中,我从
Kafka
主题读取事务,处理事务,然后将它们发送到IBM。当没有与IBM的连接时,我试图处理这个错误,以防止事务丢失。期望的行为是事务保持在
Kafka
主题中,而流侦听器再次读取它。然而,消息似乎只被消耗了一次,并且没有发生“回滚”。要做到这一点,以下是我的心声:
cloud
:
kafka
: input:con
浏览 1
提问于2019-08-02
得票数 1
回答已采纳
1
回答
如何暂停消费者在
spring
云流中消费消息
spring-boot
、
spring-amqp
、
spring-cloud-stream
我遇到了这样的情况,我想暂停消费者停止通过
spring
boot应用程序消费消息,并且消息不应该从队列中丢失,我正在使用amqp和
spring
cloud
stream
。https://github.com/
spring
-
cloud
/
spring
-
cloud
-
stream
/blob/master/docs/src/main/asciid
浏览 44
提问于2019-03-31
得票数 0
1
回答
使用
Kafka
绑定器在
Spring
cloud
中打印JsonObject
spring-boot
、
java-8
、
apache-kafka-streams
、
spring-cloud-stream
我是
Spring
Cloud
和
kafka
stream
的新手。我正在尝试使用
kafka
活页夹
设置
spring
cloud
应用程序。我尝试在本地测试
kafka
流处理器,但无法打印任何日志。return true;});
spring
.
cloud
浏览 37
提问于2021-07-27
得票数 0
回答已采纳
1
回答
异常未嵌入到DLQ中
spring-cloud-stream
、
spring-cloud-dataflow
、
spring-kafka
我已经用
kafka
活页夹
设置了一个春天的云流。正如前面提到的,我还启用了DLQ并设置了headerMode来捕获异常消息。然而,当有异常时,我只在我的
kafka
主题中看到消息,而没有异常详细信息。我的application.yml看起来像这样 application:
cloud
: defaultBinder:
kafka
defau
浏览 4
提问于2017-10-13
得票数 1
2
回答
Spring
Cloud
与
Spring
Kafka
签约
spring-kafka
、
spring-cloud-contract
Spring
Cloud
Contract是否支持
Spring
Kafka
消息开箱即用的contract验证?
浏览 1
提问于2017-02-16
得票数 1
1
回答
春云流卡夫卡多重消费者。是否有方法分别为每个使用者配置反序列化器?
spring-cloud-stream
我使用的是带有卡夫卡绑定的小枝云流。我有多个不同内容类型的消费者。是否有一种方法可以配置反序列化器的基础上?
浏览 0
提问于2021-03-16
得票数 0
回答已采纳
1
回答
弹簧云卡夫卡绑定查询
java
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在使用
活页夹
,一切都很好。突然,我们观察到生产者正在向主题发送重复的信息,然后我们使生产者是幂等的。为了更好的控制,我们让autocommitOffSet做错了。我还设置了以下事务属性
spring
.
cloud
.
stream
.
kafka
.binder.transaction.transactionIdPrefix=TX-
spring
.
cloud
.
stream
.
kafka
.binder.transaction.producer.co
浏览 3
提问于2021-09-28
得票数 0
1
回答
如何使用
Spring
云流
kafka
实现
Kafka
@RetryableTopic?
spring
、
apache-kafka
、
spring-kafka
、
spring-cloud-stream-binder-kafka
使用@阻止
kafka
重试。我注意到卡夫卡
活页夹
的重试是可行的,但它并没有引入预期的延迟。
浏览 5
提问于2022-07-09
得票数 0
1
回答
弹簧云流卡夫卡度量标准没有显示在执行机构的度量中
spring-boot
、
apache-kafka
、
spring-cloud
、
spring-cloud-stream
、
spring-boot-actuator
{"jvm.buffer.memory.used","jvm.memory.committed", acknowledge-mode: AUTO concurrency: 10
stream
浏览 6
提问于2020-07-06
得票数 1
回答已采纳
1
回答
Spring
Cloud
Stream
Kafka
绑定器KafkaTransactionManager在应用上下文中产生循环
spring-boot
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在使用
Kafka
设置一个基本的
Spring
Cloud
Stream
producer。其目的是接受HTTP POST,使用
Spring
Data JPA将post的结果保存到数据库,并使用
Spring
Cloud
Stream
Kafka
Binder将结果写入
Kafka
主题。我正在学习如何设置KafkaTransactionManager的最新
活页夹
documentation,但此代码在应用
浏览 25
提问于2021-07-01
得票数 0
回答已采纳
2
回答
如何改变春云流卡夫卡绑定的目标?
docker
、
apache-kafka
、
spring-cloud
、
spring-kafka
、
spring-cloud-stream
到目前为止,这是我的projetc配置的摘录:
spring
.
kafka
.streams.bootstrap-servers=PLAINTEXT://localhost:9092
spring
.
cloud
.
stream
.
kafka
.binder.brokers=PLAINTEXT:/
浏览 3
提问于2019-11-08
得票数 1
回答已采纳
1
回答
春云流功能手册确认- KafkaHeaders.ACKNOWLEDGMENT不可用
kafka-consumer-api
、
spring-webflux
、
spring-cloud-stream
我使用和功能接口来处理我的
kafka
处理。application.yml (相关部分)
cloud
:
kafka
: brokersminPartitionCount: 2 receiver-in-0:
浏览 1
提问于2020-04-22
得票数 0
回答已采纳
1
回答
弹簧云卡夫卡流绑定器transactionIdPrefix性能命中
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
=TX-
spring
.
cloud
.
stream
.
kafka
.binder.transaction.producer.configuration.ack=allspring.
cloud
.
stream
.
kafka
.binder.transaction.producer.configuration.retries=10
spring
.
cloud
.
stream
.
kafka
.bindings.input.con
浏览 5
提问于2021-10-04
得票数 0
1
回答
多卡夫卡绑定弹簧云数据流
spring-cloud-dataflow
卡夫卡-基地1应该是默认的,卡夫卡-基地2可以作为输出
活页夹
在定义或部署属性中提供,例如: app.bridge.
spring
.
cloud
.
stream
.bindings.output.binder=
kafka
-qa2我的SCDF application.yaml包含两个绑定:
cloud
: applicationProperties: <e
浏览 6
提问于2017-02-03
得票数 0
回答已采纳
2
回答
春季云流卡夫卡消费者会不会消费服务中断时发送的消息?
java
、
spring-boot
、
apache-kafka
、
spring-cloud-stream
spring
.
cloud
.
stream
.bindings.input.group=sampleconsumergroup 重置集和
spring
.
cloud
.
stream
.
kafka
.bindings.input.consumer.resetOffsets=true
spring
.
cloud
.
stream
.
kafka
.bindings.input.consumer.startOffset=latest
浏览 2
提问于2019-03-06
得票数 1
回答已采纳
1
回答
KafkaBindingRebalanceListener豆不自给多层粘结剂
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
但我对多个
活页夹
运气不好。不确定我搞砸了什么,或者这个技术只支持一个顶级的粘合剂。工作YAML (只有一个顶级绑定程序):
cloud
: definition: consume; functioninput input: group: groupA
浏览 6
提问于2020-11-16
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Spring Cloud Stream简介
Spring Cloud Stream简单入门
Spring Cloud Stream如何处理消息重复消费?
精通springcloud:消息驱动的微服务,了解Spring Cloud Stream
Spring Cloud ELK+kafka日志分析平台搭建
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券