我试图从具有模拟数据的服务返回一个Observable.
我从我的服务中退回来了:
return Observable.of(new Object()).map(MOCKACCOUNT =>JSON.stringify(MOCKACCOUNT));
我收到一个错误
Observable_1.Observable.of不是一个函数.
我错过了一些包括？我正在进口
import {Observable} from "rxjs/Observable";
注意:我之前返回了一个模拟承诺,但根据我的理解,我无法插值.例如{{returnFromServiceStoredInExportedClass.name}}
我有一个json数组,可以包含我想要加载的组件的组件或html选择器.我试图在for循环中加载这些数据.当我尝试插入值{{d.html}}时,它会显示为计划文字.当我使用下面的innerHTML方法并检查dom时,我看到那里的html,但它不像一个自定义组件(dom只包含而不是初始化它并用组件模板替换它).
我看过动态内容加载器,但看起来不合适.这是for循环,因此不能使用模板语法,因此loadIntoLocation不适合我.如果组件有任何输入,也不确定它是如何工作的.
<div *ngFor="#d of dtabs" class="tab-pane" id="tab-{{d.component}}">
<div [innerHTML]="d.html"></div>
</div>
我的路由定义为/ abc /:id/xyz
其中abc /:id解析为ComponentA,而/ xyz是路由器插座中显示的子组件(ComponentB)
当导航到/ abc /:id/xyz时,当我在ComponentA中执行this.route.params.subscribe(...)(其中route是ActivatedRoute)时,我看到:id.在ComponentB中做同样的事情我没有看到:id.我猜ActivatedRoute正在使用url段.
无论如何要获得路线中的所有参数？
我试图了解 Connect 为您购买了什么而 Streams 没有。我们有应用程序的一部分，我们想在其中使用一个主题并写入 mariadb。
我可以用一个简单的处理器来完成这个。读取记录，存储在状态存储中，然后批量插入到 mariadb 中。
为什么这是一个坏主意？JDBC Sink Connector 给你带来了什么？
根据文档（https://docs.confluence.io/current/streams/developer-guide/manage-topics.html#internal-topics），内部主题遵循命名约定<application.id>-<operatorName>-<suffix>。
我们有一些例子：
testapplication-KSTREAM-REDUCE-STATE-STORE-0000000008-repartition
testapplication-KSTREAM-REDUCE-STATE-STORE-0000000027-repartition
有谁知道整数是如何确定的？
不幸的是，我们的安全要求不允许我们使用我们的应用程序创建主题，并且需要提前设置。我正在尝试确定这些主题名称是否一致。
文档不清楚。我什么时候想将保留重复项设置为假/真。这是做什么用的？它是针对 RocksDB 中的特定内容吗？
挖掘流内部代码似乎被用来设置一些序列号？
RocksDBWindowStore.java
private void maybeUpdateSeqnumForDups() {
if (this.retainDuplicates) {
this.seqnum = this.seqnum + 1 & 2147483647;
}
有没有办法限制或定义 kafka 流应用程序的最大内存使用量？我已经启用了状态存储的缓存，但是当我在 Openshift 中部署时，我的 pod 被 OOM 杀死了。我已经检查过我没有内存泄漏，并且我所有的状态存储迭代器都正在关闭。
我已经将我的 RocksDbConfigSetter 更新为https://github.com/facebook/rocksdb/wiki/Setup-Options-and-Basic-Tuning#other-general-options 中的建议，但没有运气。
当我查看 state store 目录时，大小约为 2GB。目前有 50GB 的内存分配给应用程序，但它仍然 OOM
引用本文档的 4.2.6 https://docs.spring.io/spring-kafka/reference/htmlsingle/#kafka-streams
您如何使用 kafka 流弹簧支持访问状态存储？
没有春天你能做什么？
StreamsBuilder builder = ...;
// Start an instance of the topology
KafkaStreams streams = new KafkaStreams(builder, config);
...
// Get the key-value store CountsKeyValueStore
ReadOnlyKeyValueStore<String, Long> keyValueStore =
streams.store("CountsKeyValueStore", QueryableStoreTypes.keyValueStore());
但我不确定如何访问 KafkaStreams 对象。
我知道可以使用 dsl api 执行连接。由于各种原因，我们需要使用处理器 api。
如何使用处理器 api 实现加入流。我有一些想法，但不认为它们是正确的。
具有多个源主题的一个处理器。流程接口的基础对象，然后在流程方法中转换为正确的类型。
两个处理器，每个处理器都有自己的源主题。每个处理器都获得对其他处理器状态存储的只读访问（如果可能）。
任何想法 - 我确实在 KStreamImpl 中找到了 join 实现，但在遵循时遇到了问题。也许是关于 dsl 如何做到的解释？