我最近将桌面版 Docker 更新到最新的 Edge 通道版本:Windows 10 机器上的 2.1.1.0。不幸的是,更新后,Kubernetes 不再工作,因为它总是停留在“Kubernetes 正在启动”。
到目前为止,我已经尝试了以下方法。
似乎没有任何工作。我该如何解决?
我试图调试在字符串内搜索的问题,它归结为以下有趣的代码片段。
\n\n两者"item "和"item "看起来相等,但事实并非如此!
var result = ("item\xc2\xa0" === "item ");\r\n\r\ndocument.write(result);\r\nconsole.log(result);Run Code Online (Sandbox Code Playgroud)\r\n通过将其粘贴到 Python 解释器上进一步研究后,我发现第一个"item "有不同类型的空格,如"item\\xc2\\xa0". 我认为这是一个不间断的空间。
现在,匹配这些字符串的一个可能的解决方案是用\\xc2\\xa0空格替换,但是是否有更好的方法将所有特殊空格字符转换为普通空格?
我有一个Kafka stream应用程序,该应用程序在传入状态下运行,并且需要在写入下一个主题之前存储该状态。只有在本地存储中更新状态后,才应执行写操作。
这样的事情。
stream.map(this::getAndUpdateState)
.map(this::processStateAndEvent)
.to("topicname");
Run Code Online (Sandbox Code Playgroud)
这样getAndUpdateState()我就能做到
state = store.get(key); // or new if null
state = updateState(state, event); // update changes to state
store.put(key, state); // write back the state
return state;
Run Code Online (Sandbox Code Playgroud)
如何在kafka商店上实现该简单的get()和put()操作?我已经尝试使用KeyValueStore但是它遇到了问题,因为我必须将其添加为源处理器和接收器处理器。
另外,也可以使用KTable或其他一些概念来获取和放入kafka。