《流程》专题

我正在编程。我想捕获并使用每一帧进行处理。视频流是根据协议从捕获的。我使用Vmax摄像机（型号:vx-1311FHB，支持)。我还使用库从以下URL捕获视频： rtsp://192.168.1.66:554/streaming/channels/1？transportmode=unicast&profile=profile_1 但我看不到卡默拉的任何回应或影像。 我在VLC媒体播放器上测试这个ur

我正在导入一个DB，其中包含一些表示多对多和一对多关系的链接表。 1-到目前为止，根据我对Kafka流的理解，我似乎需要为每个链接表提供一个流，以便执行聚合。KTable将不可用，因为记录是按键更新的。但是，聚合的结果可能是Ktable中的一个。 2-然后是外键上的连接问题。似乎唯一的方法是通过GlobalKtable。link-table-topic->link-table-stream->li

我想使用Kafka Streams API对带有KTable的KStream执行左联接，将表的一些字段添加到流中。 使用包含所有相关条目的较小版本的表（大约1300个条目），一切工作都很好。 使用整个表（大约200,000个条目）后，在获得KTable的Avro消息（GenericRecord）的相关字段的行中会得到一个。 当我在KSQL中执行相同的左联接操作时，从表中添加的字段为NULL。相关的

来自jvisualvm的快照

我尝试使用Kafka流将一个带有String/JSON消息的主题转换为另一个作为Avro消息的主题。 并得到如下所示的异常： 这是正确的做法吗？我对Kafka溪流和阿夫罗是新来的

我有一个Apache Kafka2.6制作人，它写的主题-A(TA)。我还有一个Kafka streams应用程序，它使用TA并写入topic-B（TB）。在streams应用程序中，我有一个自定义的时间戳提取器，它从消息负载中提取时间戳。 对于我的一个失败处理测试用例，我在应用程序运行时关闭了Kafka集群。 当生产者应用程序试图向TA写入消息时，它无法写入，因为集群已关闭，因此（我假设）缓冲了

我已经将kafka代理从0.8升级到0.11，现在我正在尝试升级火花流作业代码以与新的kafka兼容-我正在使用火花1.6.2-。 我搜索了很多步骤来执行此升级，我没有找到任何官方或非官方的文章。 我发现唯一有用的文章是这篇，但是它提到了spark 2.2和kafka 0.10，但是我得到一行文字说 但是，由于较新的集成使用新的 Kafka 使用者 API 而不是简单的 API，因此在用法上存在显

我有一个KStream,其中包含从主题到1的数据,如下所示： 和KTable,构造如下： 稍后,主题To2中出现以下消息： 现在，我希望我的KTable能够反映这些变化，并且看起来像这样： 但看起来是这样的： 我想我缩小了范围：显然聚合的只在第一次调用--之后聚合总是接收作为最后一个参数，例如。 其中，在第一次调用（通过初始值设定项创建）时为，但在第二次调用时为。 有什么想法吗？ 编辑2 编辑3

我的目标是从主题A消费，做一些处理和生产到主题B，作为单个原子动作。要做到这一点，我有两种选择： null 我已成功验证选项#1。所谓成功，是指如果我的处理失败（抛出IllegalArgumentException），来自主题A的已消费消息将继续被KafKalistener消费。这是我所期望的，因为没有提交偏移量，而使用了DefaultAfterRollbackProcessor。 我希望看到相同

通过按暂停并重新播放，它再次正确工作，但我如何解决这个问题而不重新启动播放器？ 提前谢了。

我有这个代码，用于使用tenorflow hub的预训练通用编码器构建语义搜索引擎。我无法转换为tlite。我已将模型保存到我的目录中。 导入模型： 根据数据训练模型: 保存模型: 保存工作正常，但当我转换到tflite它给出错误。 转换码： 错误:

很多次，当我试图在UI中打开某些DAG的树状视图或任务持续时间页面时，我得到错误：504网关超时。有时在那之后，我甚至无法打开包含DAG列表的页面。你知道这个问题可能来自哪里吗？ 运行Airflow的机器的CPU和内存似乎很好，我使用RDS作为元数据。 谢谢！

我需要过滤一个列表

现在你已经学会新建和合并分支，那么你可以或者应该用它来做些什么呢？ 在本节，我们会介绍一些常见的利用分支进行开发的工作流程。而正是由于分支管理的便捷，才衍生出这些典型的工作模式，你可以根据项目实际情况选择一种用用看。 长期分支 因为 Git 使用简单的三方合并，所以就算在一段较长的时间内，反复把一个分支合并入另一个分支，也不是什么难事。 也就是说，在整个项目开发周期的不同阶段，你可以同时拥有多个开