腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
用
spring-cloud-stream
和
函数
风格
暂停
Kafka
Consumer
apache-kafka
、
functional-programming
、
spring-cloud-stream
我正在尝试为我的
kafka
流应用程序实现一个重试机制。其想法是,我将从输入主题中获取使用者
和
分区ID以及主题名称,然后在有效负载中存储的持续时间内
暂停
使用者。我搜索过文档
和
示例,但我找到的都是基于
spring-cloud-stream
提供的经典绑定的示例。我正在尝试看看是否有一种方法可以
用
函数
式
风格
访问这些信息。@StreamListener(Sink.INPUT) public void in(String in, @Header(KafkaHead
浏览 194
提问于2021-02-10
得票数 0
回答已采纳
1
回答
如何知道
kafka
-spring云流中是否所有消息都已被消费
spring-cloud-stream
我们在有条件的基础上触发
Kafka
消费者。如何知道该主题的所有消息是否都已被消费。
浏览 90
提问于2021-10-26
得票数 0
1
回答
无法检测消息路由器
spring-cloud
、
spring-cloud-stream
我试着
用
一个简单的Sink来记录来自卡夫卡主题的消息public class ReadEMPMesage { logger.info("Received" + ccpEvent);我的配置如下spring.
kafka
.
consumer
.auto-offset
浏览 0
提问于2018-02-14
得票数 3
1
回答
如何在Spring Cloud Stream
Kafka
绑定中编写订阅topic的方法?
java
、
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我想编写一个使用KafkaListener订阅主题的消费者方法。@KafkaListener(id = "foo", topics = "dead-out") System.out.println("DLQ:" + in);现在,在注释‘topic’中是订阅主题的名称。但是什么是'id‘字段呢?还是有更好的方法?
浏览 33
提问于2020-05-13
得票数 0
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/asciidoc/spring-cloud-stream.adoc#binding_visualization
浏览 44
提问于2019-03-31
得票数 0
1
回答
春云流消费者没有阅读卡夫卡主题的信息
spring-boot
、
apache-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在尝试使用spring应用程序中的
kafka
主题。我使用的是Spring云流
和
下面提到的版本下面是代码
和
配置springgroup:
kafka
-log-group concurrency: 10讯息使用者类别p
浏览 4
提问于2021-11-29
得票数 2
1
回答
春云流卡夫卡-抓起大块头,错过心跳。
apache-kafka
、
spring-cloud
、
spring-cloud-stream
唯一的属性集是主题本身有20个分区,应该适合。当监视
kafka
的读取时,我们发现吞吐量很低,行为也很奇怪:spring.cloud.stream.bindings.
consumer
.<input>.configurationspring.cloud.stream.
kafka
.binders.
consumer<
浏览 0
提问于2019-02-28
得票数 3
回答已采纳
2
回答
Spring Cloud Stream &
Kafka
:
Kafka
生产者序列化错误
spring-boot
、
spring-cloud-stream
、
kafka-producer-api
我对Spring Cloud Stream
和
Kafka
都是新手。在有效负载中发送字符串时,我从
kafka
生产者收到以下错误。任何帮助或见解都是非常感谢的。错误消息: org.apache.
kafka
.common.errors.SerializationException:无法将类[B ]的值转换为value.serializer中指定的类org.apache.
kafka
.common.serialization.StringSerializerCaused by: org.apache.
kafk
浏览 0
提问于2019-10-26
得票数 1
2
回答
Confluent python
暂停
-恢复功能示例
python
、
python-3.x
、
apache-kafka
、
confluent-platform
试图使用融合卡夫卡消费者的
暂停
和
恢复功能,但在互联网上找不到任何例子,除了主要的链接。 无法理解要传递给它的参数。或者是它的病人名单或者主题名称什么的?
浏览 0
提问于2018-10-12
得票数 1
1
回答
Spring-Cloud-Stream-
Kafka
-Binder
函数
式
风格
忽略了自定义的反/序列化
和
/或useNativeEncoding?
java
、
spring-boot
、
apache-kafka
、
spring-cloud-stream
我们刚刚升级到
Spring-Cloud-Stream
的3.0.0版本,遇到了以下问题: 当像这样使用
函数
式样式时: public class EventProcessor { binder: auto-create-topics: false
consumer
: useNativeDecod
浏览 29
提问于2019-12-17
得票数 1
1
回答
卡夫卡消费者架构设计: java插件还是外部客户端
java
、
design-patterns
、
architecture
、
apache-kafka
、
consumer
我正在为
kafka
集群(使用dockers for
kafka
)为数据使用者编写解决方案,但我仍然需要决定如何对其进行编码: Java (使用K
浏览 1
提问于2018-12-20
得票数 0
回答已采纳
1
回答
Spring-Cloud-Stream
process
kafka
消息仅在应用程序启动时实现的状态存储已完全填充并准备就绪后才能处理
java
、
spring-boot
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
引用此solution,我的
spring-cloud-stream
application.yml文件具有以下配置: #application.yml destination: my-topic-name
consumer
: <e
浏览 28
提问于2019-05-09
得票数 0
1
回答
将消息发送到运行时定义的
Kafka
主题
java
、
spring-kafka
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
spring.cloud.stream.bindings.output.binder=
kafka
spring.cloud.stream.bindings.output.destination=user-events
浏览 23
提问于2021-02-10
得票数 0
2
回答
Kafka
Streams - java版本依赖关系
apache-kafka-streams
我正在使用Java1.6运行我的应用程序,并计划将一些方面与
Kafka
集成。 我正在探索是否应该使用
Kafka
Consumer
(使用poll())或使用KafkaStreams API。
浏览 3
提问于2018-12-20
得票数 0
1
回答
如何解决Streams流绑定中多路输入主题的InvalidTopicException问题?
java
、
spring
、
apache-kafka
、
apache-kafka-streams
、
spring-cloud-stream
process-in-0:(资料来源:)2022-06-17 14:07:07.648 INFO --- [-StreamThread-1] o.a.k.clients.
consumer
.KafkaConsumer : [
Consumer
: [
Consumer
clientId=test-processor-2ba8d1d3-5bbe-45
浏览 16
提问于2022-06-17
得票数 0
回答已采纳
2
回答
KAFKA
节点:管理多个消费群体
node.js
、
apache-kafka
我有一个关于管理多个CG的问题,创建了三个消费者组,每个CG都有自己的
kafka
服务、组Id
和
主题。现在我收到了预期的消息,但是,我想知道是否有可能创建下一个场景: for(let i = 0; i < confi
浏览 1
提问于2018-07-12
得票数 2
回答已采纳
2
回答
spring-cloud-stream
示例项目提升KafkaStreamsFunctionProcessor的NoSuchBeanDefinitionException
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我正在尝试使用
spring-cloud-stream
,并创建official blog的示例项目。 实现与本文完全相同。SpringBootApplication public java.util.function.
Consumer
System.out.println("Key: " + key + " Value: " + value); } } 我在Spring i
浏览 34
提问于2021-04-12
得票数 0
2
回答
如何在
Kafka
nodejs中延迟消费消息?
node.js
、
elasticsearch
、
apache-kafka
、
elasticjs
我正在使用NodeJS消费来自
Kafka
的消息,收到消息后,我会带着它在Elasticsearch中创建索引。
浏览 0
提问于2016-05-31
得票数 0
1
回答
为什么我的春季云流配置会创建多个
kafka
消费者?
spring-boot
、
spring-kafka
、
spring-cloud-stream
我有一个非常简单的spring云流消费者设置,针对当地的
Kafka
代理。这是spring的配置 cloud: bindings: destination: test-topic而消费者阶层本身:
Consumer
<Message<String>>
consumer
() { return为了清晰起见,我使用了S
浏览 7
提问于2021-04-14
得票数 0
回答已采纳
1
回答
卡夫卡消费者关机后信息丢失状态
python
、
message-queue
、
apache-kafka
我把
kafka
和
python的消费者一起使用。当消费者运行起来,信息被推送到卡夫卡,然后被消费者阅读时,一切都很好。然而,如果消费者因为任何原因而下降,当它回来的时候,它只读取新的信息,这些信息是在消费者恢复后发布到
kafka
的。关机-电源之间的消息丢失了,也就是说,用户在恢复后不会读取这些消息。
consumer
= KafkaConsumer(..) 就是我用来创造消费者的东西。
浏览 3
提问于2016-01-08
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
python自动化部署docker容器消费kafka
浅谈分布式消息技术:Kafka
Kafka 运维纪实-一次磁盘故障后消费者无法消费
浅入浅出kafka
每日三问合辑五
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券