我使用StreamsBuilder的simply API构建一个GlobalKTable,如下所示:
Materialized<Long, Category, KeyValueStore<Bytes, byte[]>> materialized =
Materialized.<Long, Category, KeyValueStore<Bytes, byte[]>>as(this.categoryStoreName)
.withCachingDisabled()
.withKeySerde(Serdes.Long())
.withValueSerde(CATEGORY_JSON_SERDE);
return streamsBuilder.globalTable(categoryTopic, materialized);
我希望收到变更通知。它很少更新,如果更新,我想触发缓存失效。Kafka的做法是什么?
GlobalKTable不支持这一点。但是,您可以使用“全局存储”并实现自定义的处理器
,每次更新都会调用该处理器。
在内部,GlobalKTable
使用“全局存储”,并为您提供处理器
实现。
您可以通过StreamsBuilder#addGlobalStore()
添加全局存储。
问题内容: constructor(){ super(); this.state = { address: { street:null, city:null, postalCode: null } }; } postalCodeChange(e){ this.setState.address.postalCode = e.target.value; console.log(this.state);
本文向大家介绍如何更新组件的状态?相关面试题,主要包含被问及如何更新组件的状态?时的应答技巧和注意事项,需要的朋友参考一下 ReactDOM.render this.setState this.forceUpdate useState useReducer
我有一个组件,看起来像: 它从datepicker组件获取currentDate属性,如下所示: 当我从日期选择器中选择新日期时,this.props.current子组件上的日期会更新。这是我想要的日期。但是,当更新该prop时,它不会用新的预期数据重新呈现表。我意识到我必须更新子表的状态才能重新渲染。我试图通过设置当前日期:this.props.current日期来设置ftchData()方法
我想用我自己的推送通知图标替换默认图标。 现在,应用程序将图标显示为白色框。
说明 支付宝境外到店支付-更新商户二维码状态 官方文档:https://global.alipay.com/service/merchant_QR_Code/34 类 请求参数类 请求参数 类名:\Yurun\PaySDK\AlipayCrossBorder\InStore\ModifyStatus\Request 属性 名称 类型 说明 $service string 接口名称 $timesta
描述 如果在调用 融资申请创建API 时填写了 callbackURL 参数,当资金方反馈审批结果时,会通过此接口下发回调通知。 此接口统一使用 POST 请求进行参数传递,body 内容为明文,只要返回的 HTTP 返回的状态码为200即认为回调成功,否则会最多重试3次,每次间隔3分钟。 某个申请一旦回调成功,或回调重试次数达到3次,则不会再次通知(但可以通过申请状态查询接口进行主动查询)。 请