《机制》专题

但是Flink医生说： 在启用Flink检查点的情况下，Flink Kafka使用者将使用来自主题的记录，并以一致的方式定期检查其所有的Kafka偏移量以及其他操作的状态。在作业失败的情况下，Flink会将流程序恢复到最新检查点的状态，并从检查点中存储的偏移量开始重新使用来自Kafka的记录。 阅读其他来源，我猜Flink检查点将保存程序的状态以及消耗的偏移量，但Spark检查点只是保存消耗的偏移

我正在尝试理解kotlin协程，我来自C#，在kotlin中有一些我不理解的地方。在这种情况下，我正在使用Qukus框架中的静态编程语言编写一个webapi。从我可以看出，如果我将控制器（或资源）函数标记为挂起函数，Qukus将自动在协程中启动它。 我的问题是，我不知道挂起该协程的首选方法是什么。我在kotlin协程上看到的绝大多数示例都使用delay（）函数，该函数在内部使用suspendCan

我一无所获。我尝试了从将文件从主机复制到Docker容器的所有建议 使用tar似乎很棒，而不是直接去底层FS。但我不能假设焦油会出现在所有容器中。 如果是相关的，我甚至尝试在容器中创建一个文件，但它然后做了一个查找。-在/var/lib/docker/devicemapper/mnt中命名无效。

我们的假设是poller会将接收到的消息交给task executor进行处理，但是task executor中的消息不会超过64条，而task executor可以容纳256+16条消息。 然而，我们看到异常，队列容量已经达到，任务执行器拒绝任务。我们认为这是因为任务执行器仅由轮询器使用，并在轮询线程上处理获得的请求。由于处理需要很长时间，我们慢慢地用轮询任务淹没任务执行器。并在单个线程中处理它

我计划在key vault上保留密钥，但我不清楚密钥和秘密的版本控制，我有一些关于Azure key vault上的key/Secret的版本控制的问题。 如何创建现有密钥的新版本？ 是否可以解密用不同版本的相同密钥加密的数据？ 是否可以为某个版本的密钥设置过期日期？

我正在学习如何使用Flink处理流数据。 根据我的理解，我可以多次使用函数进行各种转换。 表示数据源不断向Flink发送字符串。所有字符串都是JSON格式的数据，如下所示： 下面是我的代码： 正如您所看到的，我的示例非常简单：获取并反序列化数据-->将string转换为Json对象-->将Json对象转换为string并获取所需内容（这里只需要)。 就目前而言，似乎一切都很好。我确实从日志文件中获

我想在文件中复制安装过程中的所有文件。 它不会将文件夹和文件复制回我的主机。 能让它发生吗？

早在2007年，我就用Java编写了一些软件来控制Epson TM90收据打印机。我的软件使用JavaPOS API。 这个JavaPOS软件似乎已经不存在了！ 2012年，从Win7通过USB从用Wava编写的应用程序驱动Epson Receipt打印机的正确方法是什么？ TIA BfW

盖伊的，我需要帮助...我得在控制台上画一个正弦波给我上大学课。但我有点纠结于如果..为什么第二个if语句不从第一个if/else语句中取新的“y_1”？也许有人能解释一下，我错在想^^多谢

我们希望使用Kafka作为我们的企业服务总线（ESB）。 我知道kafka的大多数用例都是异步用例。 在我们的系统中，是否仍然可以使用kafka在两个endpoint之间进行请求-响应消息传递？

我在用jmeter记录我的https流量时遇到问题，并且总是收到此错误消息。不过，我在记录常规流量方面没有任何麻烦。 响应代码：非HTTP响应代码：javax.net.ssl.SSLHandshakeException响应消息：非HTTP响应消息：java.security.cert.CertificateException：没有可用的X509TrustManager实现 到目前为止，我为克服这个

我们决定在web应用程序中使用乐观锁定，以增加并发性，而不使用悲观锁定。 我们在web上看到的解决方案之一是使用带有注释的重试拦截器将方法标记为可重试。 问题是，我们希望对带有@Transactional注释的方法进行注释，但拦截器由于某种原因未能重试它们。（拦截器完全重试非事务性方法。） 所以：

有人能帮我编写JAAS conf文件和Handler类以使用SASL/OAUTHBEARER进行身份验证吗？ 在kafka文档中配置的JAAS文件中，这个选项的含义是什么？

我正在编写来构建应用程序。我知道您可以使用 （请参见将文件从Docker容器复制到主机），但我只想运行 在Dockerfile中是否有一个命令可以用于从容器中复制到主机中？像的反义词吗？

我想在dockerfile成功构建时获取一些文件，但它不将文件从容器复制到主机。 这意味着当我构建dockerfile时，文件已经是主机了。