小编emi*_*ini的帖子

这是我的情景.我正在使用knockout映射插件为我创建一个可观察的viewmodel层次结构.我的层次结构中嵌套了元素.在层次结构中的特定点,我想放置一个Add按钮,在observablearray中插入该元素的新空白副本.问题是我不能只说whatArray.push(new MyObject()).

由于映射插件实际上为我创建了整个层次结构,因此我无法访问"MyObject".所以我似乎唯一可以做的就是插入一个新项目来查看前一个项目并复制它.我尝试了ko.utils.extend函数,但这似乎并没有成为一个真正的克隆.它给了我一个对象,但是当我更新该对象时,它仍然会影响它从中复制的原始对象.

参见jsfiddle 示例

我有一个有数据流的主题。我需要的是从该主题创建一个单独的主题，该主题仅具有给定键的最新值集。

我认为 KTable 的全部目的是存储给定键的最新值，而不是存储整个事件流。但是我似乎无法让它发挥作用。运行下面的代码会生成密钥库，但该密钥库 (maintopiclatest) 中有一个事件流（不仅仅是最新的值）。因此，如果我在主题中两次发送包含 1000 条记录的请求，而不是看到 1000 条记录，而是看到 2000 条记录。

var serializer = new KafkaSpecificRecordSerializer();
var deserializer = new KafkaSpecificRecordDeserializer();

var stream = kStreamBuilder.stream("maintopic",
    Consumed.with(Serdes.String(), Serdes.serdeFrom(serializer, deserializer)));

var table = stream
    .groupByKey()
    .reduce((aggV, newV) -> newV, Materialized.as("maintopiclatest"));

另一个问题是，如果我想将 KTable 存储在一个新主题中，我不知道该怎么做。为了做到这一点，似乎我必须把它转回一个流，以便我可以在它上面调用“.to”。但是，其中包含整个事件流，而不仅仅是最新的值。

有谁知道为什么我的Angular2应用程序首次加载页面时会出现此错误？当我浏览我的应用程序时，它会清除并且不会回来。如果我按CTRL + F5，它往往会回来（尽管不是每次都！）。此应用的路由如下所示：

AppComponent.ts
  LoginComponent.ts
  DashboardComponent(Parent route with its own child routes)
    MainDashboardComponent
    EmployeesComponent

顶级index.html文件中包含该<my-app></my-app>标签，该标签会定期报告该错误，因此我感到困惑，因为它无法在页面上看到该标签！

错误详情：

例外：选择器“ my-app”与任何元素都不匹配。BrowserDomAdapter.logError@ angular2.dev.js：22823BrowserDomAdapter.logGroup @ angular2.dev.js：22834ExceptionHandler.call @ angular2.dev.js：1163（匿名函数）@ angular2 .dev.js：12481NgZone._notifyOnError @ angular2.dev.js：13405collection_1.StringMapWrapper.merge.onError @ angular2.dev.js：13309run @ angular2-polyfills.js：141（匿名函数）@ angular2.dev.js：13328zoneBoundFn @ angular2-polyfills.js：111lib $ es6 $ promise $$ internal $$ tryCatch @ angular2-polyfills.js：1511lib $ es6 $ promise $$ internal $$ invokeCallback @ angular2-polyfills.js：1523lib $ es6 $ promise $$内部$$发布@ angular2-polyfills.js：1494（匿名函数）@ angular2-polyfills.js：243microtask @ angular2.dev.js：13360run @ angular2-polyfills.js：138（匿名函数）@ angular2.dev.js ：13328zoneBoundFn @ angular2-polyfills.js：111lib $ es6 $ promise $ asap $$ flush @ …

根据以下链接，我应该能够将retention.policy值设置为"compact,delete".

https://issues.apache.org/jira/browse/KAFKA-4015

https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A+Enable+log+compaction+and+deletion+to+co-exist

但是，当我尝试通过运行来更改保留策略时：

./kafka-configs.sh --zookeeper $KAFKAZKHOSTS  --entity-type
 topics --alter --add-config cleanup.policy=compact,delete --entity-name topicname

我收到以下错误：

requirement failed: Invalid entity config: all configs to be added must be in the format "key=val".