腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
不同
的
KafkaStreams
之间
共享
本地
存储
apache-kafka-streams
给定:有两个具有数字用户线路拓扑
的
KafkaStreams
。
本地
状态
存储
被添加到其中一个类型中。让第二个KafkaStream更新第一个
KafkaStreams
中
的
本地
存储
的
最佳方式是什么?我可以考虑
在
带有
本地
存储
的
KafkaStreams
中添加一些处理器。这个处理器有(1)一些由第二个KafkaStream填充
的
静态任务列表,
浏览 18
提问于2019-01-25
得票数 0
1
回答
如何在两个Kafka流
之间
使用持久化StateStore
apache-kafka
、
apache-kafka-streams
我遇到了一些困难,试图通过卡夫卡流实现以下目标: val builder = new StreamsBuilderS() Stores.persistentKe
浏览 3
提问于2019-04-12
得票数 3
1
回答
Kafka Stream Punctuator
在
重建数据时访问
本地
存储
数据
java
、
apache-kafka-streams
我感觉
在
Java库重新构建
KafkaStreams
时,标点符号能够访问
本地
存储
数据,重放changelog主题中
的
项目 让我们来描述一下哪个是我们
的
场景:我有一个
KafkaStreams
应用程序A(用Java语言编写),在这个应用程序中,我们使用一个主题“into topic”,将一些对象放入一个
本地
存储
中,并使用一个时间戳加上一些唯一
的
id作为键,如下所示: key -> 201906122345它们被读取,
浏览 28
提问于2019-06-18
得票数 0
1
回答
状态
存储
,comp
存储
,可能已经迁移到另一个实例
apache-kafka
、
apache-kafka-streams
我正在创建一个
本地
商店,以保存来自特定主题components
的
所有更新。我不知道我做错了什么。还有其他方法可以从Stream创建
存储
吗? final
KafkaStreams
streams = new
KafkaStreams
(builder
浏览 0
提问于2019-05-09
得票数 0
回答已采纳
1
回答
当一个实例发生故障转移时,驻留在kafka流实例中
的
本地
状态
存储
无法同步
apache-kafka
、
apache-kafka-streams
我
在
本地
机器上运行多个kafka流消费者实例(2个实例),每个实例都有自己
的
自定义
本地
存储
,并且每个实例都有
不同
的
名称。根据文档,如果其中一个实例宕机,那么kafka必须将死实例
的
存储
同步到活实例
的
存储
(如果我错了,请纠正我)。 我已经为两个实例配置了相同
的
应用id,让kafka知道这些实例属于同一个组。当其中一个实例被杀死时,其他(活
的
)实例
的
浏览 1
提问于2019-06-21
得票数 0
1
回答
卡夫卡流处理器线程安全?
java
、
multithreading
、
apache-kafka-streams
我知道之前有人问过这个问题:线程id: 90 ID: c667e669-9023-494b-9345-23677
浏览 2
提问于2017-11-05
得票数 3
回答已采纳
1
回答
状态
存储
可能已迁移到另一个实例。
apache-kafka
、
apache-kafka-streams
当我试图从流访问状态
存储
时,我得到了以下错误。当我试图从商店访问ReadOnlyKeyValueStore时,当迁移到其他服务器时,会得到错误消息。java.util.stream.Stream; import org.apache.kafka.streams.
KafkaStreams
stream = new
KafkaStreams
(builder
浏览 1
提问于2019-04-03
得票数 2
2
回答
使用UncaughtExceptionHandler重新启动或关闭流
的
正确方法
apache-kafka-streams
我有一个流应用程序与下面的驱动程序代码
的
实时消息转换.streams.setUncaughtExceptionHandler我注意到
的
一件事是,应用程序可以正常工作,直到它转换所有的待办事项,但在处理一些新消息后抛出异常! 有时,它也抛出以下未明
的
异常。处理这些错误
的
正确方法是什么?是否可以通过编程方式重新启动流
浏览 17
提问于2017-02-22
得票数 7
回答已采纳
4
回答
Kafka流-状态
存储
可能已迁移到另一个实例。
apache-kafka-streams
我正在编写一个基本
的
应用程序来测试Kafka流
的
交互式查询功能。as("test-store").withKeySerde(Serdes.ByteArray()).withValueSerde(Serdes.Integer()) streams.clean
浏览 2
提问于2018-03-15
得票数 11
1
回答
当从InvalidStateStoreException获得状态
存储
时,是否可以使用ProcessorContext?
apache-kafka-streams
当试图从
KafkaStreams
获取
本地
状态
存储
时,如果
本地
KafkaStreams
实例尚未准备好,或者状态
存储
刚刚迁移到另一个实例(重新平衡),则可以获得InvalidStateStoreException假设我们有DSL拓扑,其中包括由addStateStore添加
的
本地
状态
存储
和一些进程或转换(KStream:process或KStream::transform)。以下是我
的
问题: 当从InvalidSta
浏览 1
提问于2019-01-18
得票数 1
回答已采纳
1
回答
我可以清空当地的卡夫卡州立商店吗?
apache-kafka
、
stream
、
apache-kafka-streams
、
rocksdb
每个消费者都有自己
的
本地
国家商店与rocksdb。这个内存中
的
键值
存储
是
在
grpc调用期间调用
的
.
在
再平衡期间(如果消费者消失了),数据将被写入到其他使用者
的
本地
存储
中。是否有办法解决当地仓库增长过快
的
问题?我们可以删除不再需要
的
分区
的
数据吗?还是有一种方法可以
在
恢复使用者后删除
存储
的
数据?
浏览 3
提问于2019-12-10
得票数 1
回答已采纳
2
回答
如何连接到单个Kafka流应用程序中
的
多个集群?
apache-kafka
、
apache-kafka-streams
在
中,它说: 我是否可以创建多个
KafkaStreams
实例,它们具有连接到
不同
集群
的
不同
属性?
浏览 10
提问于2017-08-23
得票数 13
3
回答
在
相同web应用
的
实例
之间
共享
存储
javascript
、
local-storage
我构建了一个
在
多个raspberry pi上运行
的
web应用程序,我想添加由所有web应用程序实例
共享
的
存储
。基本上,我想要实现
的
是,对于我
在
浏览器中打开
的
每个实例,它将设备名称和URL保存到我
的
浏览器(
本地
存储
是我使用
的
存储
,但它不是
共享
的
),然后web应用程序将打开
存储
,读取所有以前访问过
的</em
浏览 0
提问于2017-08-11
得票数 0
1
回答
Blazor WASM跨域
本地
存储
local-storage
、
blazor-webassembly
正如我们所知道
的
,
在
不同
域
之间
共享
本地
存储
的
解决方案是使用iframe和postmessage,我已经
在
blazor服务器中使用了这一点,但是
在
blazor web程序集中,iframe中
的
函数从
本地
存储
获取项,从父域读取
本地
存储
,而不是从iframe源域读取
本地
存储
,因此返回null,有什么
浏览 5
提问于2022-10-10
得票数 0
回答已采纳
1
回答
为什么我要用Kafka流来配置一个州立商店?
apache-kafka
、
apache-kafka-streams
、
rocksdb
kafka.topics.table", maxNumMatches), "kafka.topics.table");
KafkaStreams
streams = new
KafkaStreams
(streamsBuilder.build(), streamsConfiguration); 为什么我需要
本地
状态
存储
,因为我不使用它进行任何其他计算,而
浏览 4
提问于2019-12-07
得票数 2
回答已采纳
1
回答
Kafka流多实例设计含义
apache-kafka
、
apache-kafka-streams
、
confluent-platform
问题:
在
一个JVM中拥有一个org.apache.kafka.streams.
KafkaStreams
类
的
多个实例意味着什么(EG:内存、CPU使用、并发问题)?后台:我试图提供一个散列机制,这样如果流操作抛出异常,它就不会将整个
KafkaStreams
实例转换为ERROR状态。我将应用程序划分为
不同
的
KafkaStreams
实例,每个实例负责
不同
的
任务(日志记录、外部web调用、db调用等)。我还没有找到有关以下方面的文档:(1)从
浏览 2
提问于2018-03-15
得票数 1
回答已采纳
2
回答
检查StateStore是否已完全填充
apache-kafka-streams
、
spring-cloud-stream
、
spring-cloud-stream-binder-kafka
我有一个约30 with键紧凑
的
主题。我
的
App将此主题具体化为KeyValueStore。 如何检查KeyValueStore是否已完全填充?
浏览 1
提问于2020-03-11
得票数 4
回答已采纳
4
回答
码头工人群如何实现卷
共享
?
docker
、
docker-swarm
、
docker-machine
码头工人群可以管理两种类型
的
存储
:虽然bind不是由Docker文档建议
的
,因为它在
本地
目录(
在
每个群集节点上)
之间
创建了到任务
的
绑定,但是没有提到volume实现,所以我不明白如何在任务
之间
共享
卷Docker群如何在节点
之间
共享
卷? 如果节点在
不同
的
网络上运行在
浏览 5
提问于2017-12-11
得票数 127
回答已采纳
1
回答
如何在
不同
的
web应用实例
之间
共享
Azure移动服务令牌
azure
、
azure-mobile-services
、
access-token
我计划有多个azure移动服务实例,所以我
的
第一个要求是
在
不同
的
应用程序实例
之间
共享
经过身份验证
的
用户
的
访问令牌。我找到了这篇文章,它指出,目前我们不能
共享
令牌,因为它
存储
在
本地
机器上,并且不建议将其放到blob
存储
中。目前我有什么可能
的
解决方案?
浏览 1
提问于2017-01-31
得票数 0
3
回答
Kafka流StateStore是全局
的
还是
本地
的
?
apache-kafka
、
apache-kafka-streams
在
Kafka Stream WordCount示例中,它使用StateStore来
存储
字数。如果同一个消费组中有多个实例,StateStore对该组是全局
的
,还是只对一个消费者实例是
本地
的
? 技术
浏览 0
提问于2016-10-27
得票数 12
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
浏览器本地存储与服务器端存储之间的区别是什么?
更大的灵活性:BMW Digital Key现在可以在iPhone和Android设备之间共享
在 virt-manager 的主机和客户机之间共享文件夹|Linux 中国
在 GNOME Boxes 里的客体机和宿主机之间共享文件夹|Linux 中国
随着制定法规的完善,全球汽车制造商开始在中国本地存储汽车数据
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券