《流程》专题

我试图使用kafka流库只使用一次kafka的功能。我只将proessing.guarantee配置为exactly_once。与此同时，需要将事务状态存储在内部主题（__transaction_state）中。 我的问题是，如何定制主题的名称？如果kafka集群由多个消费者共享，那么每个消费者是否需要不同的事务管理主题？ 谢谢你，墨蒂

这将产生以下结果 我所感兴趣的实际上只是上面结果中的列表，我希望理想地将其作为groupby操作的一部分来完成。我知道这是可以做到的，例如，通过循环结果映射结构。但是有没有一种方法可以使用流来实现它呢？

我正在尝试在linux上构建ffmpeg编码器。我从一个定制的服务器Dual 1366 2.6 Ghz Xeon CPU（6核）开始，具有16 GB RAM和Ubuntu 16.04最小安装。使用h264和aac构建ffmpeg。我正在获取实时源OTA频道并使用以下参数对它们进行编码/流式传输 -vcodec libx264-预设超高速-crf 25-x264opts keyint=60:min

我正在尝试使用TkinterGUI使用python/tweepy来流式传输推文。理想情况下，我会有一个启动流的“开始”按钮和一个停止流的“停止”按钮。下一个示例（来自stackoverflow）以一种简化的方式展示了我试图实现的目标： 我试图将此应用到我的代码中，开始按钮工作正常，完成了它应该做的所有事情，但停止按钮没有做任何事情。窗口没有冻结或任何东西，只是停止按钮没有效果。由于什么事也没有发生

有人能帮我做这个吗？

通过stream API，我可以编写一个RichCoFlatMapFunction来接受一个控制流和一个数据流，控制流中包含了启动、停止或改变参数的计算元素，我知道我可以存储当前控制设置的状态，并在处理数据流时检查值。 但是用Flink SQL做类似的事情的方法是什么呢？我不能使用join，因为数据流和控制流不能连接在一起。 我们提出的解决方案是通过应用程序本身存储控件设置。其想法是： > 将控制

我浏览了exoplayer的网站和文档以及Github页面，但我对其解释并不满意。 任何人都可以给我一个提示，你如何通过ExoPlayer播放一个http直播流视频？ 提前道谢。

> OAUTH2服务器使用“authorization_code”授予类型发出带有自动批准的JWT令牌。这有HTML/AngularJS表单来收集用户名/密码。 ui/webfront-使用@enablesso。它的所有endpoint都是经过身份验证的，即它没有任何未经授权的登陆页面/UI/链接，用户可以点击这些页面进入/UAA服务器。因此点击http://localhost:8080会立即将您

我在spring batch中有一份工作，包括一个阅读器、一个处理器和一个写入器。 首先，我想知道这3个组件以什么顺序运行:它们是顺序的(对于commit-interval=1)还是在写入前一个项目之前读取新项目以避免延迟？ 我对此很感兴趣，因为我有以下案例： 我想有一条“装配线”：读- 这意味着在写入前一项之前不读取任何内容。 这东西已经开箱即用了吗？如果没有，我怎么能完成这样的事情？

我正在尝试使用此代码使用代理版本0.10测试kafka流。这只是一个打印主题内容的简单代码。还没什么大不了的！但是，由于某种原因内存不足（VM中的10GB RAM）！代码： 运行火花提交： 不幸的是，结果是： java.lang.OutOfMemoryError：Java堆空间 我假设Kafka每次应该带一小部分数据来避免这个问题，对吗？那么，我做错了什么？

从我对Flink的一点经验来看，我已经注意到，即使我们有按顺序到达的事件，它们也应该在对顺序进行分区之后到达。这里讨论的是：流中记录的排序 所以我有3个问题延伸了上面提到的问题： > 我仍然不清楚keyBy函数后订单丢失的原因。为什么会发生这种情况？ 是否有办法确保即使在分区之后事件的顺序？ 如果我们不创建KeyedStreams，那么每个并行操作符的事件顺序是否有保证？

以下是我的一些疑问： 我有两个不同的流，元素按顺序排列。 1）现在，当我在这些流中的每一个上执行时，会维护顺序吗？（因为这里的每个组都将仅发送给一个任务管理器）我的理解是，记录将是一个组的顺序，在这里纠正我。 2） 在这两个流上执行按键操作后，我正在进行联合分组，以获取匹配和非匹配记录。这里也会维持秩序吗？，因为这也适用于KeyedStream。我正在使用事件时间（EventTime）和上升时间（

我想使用Flink流媒体以低延迟处理市场数据（ 我有一组计算，每个都订阅三个流：缓慢移动的参数数据、股票价格和汇率。 例如。 Params（缓慢滴答：每天一次或两次）： 资源（每秒多次滴答声）： fx（每秒多次滴答声）： 每当任何股票、外汇汇率或参数数据发生变化时，我都想立即计算结果并将其输出为新流。这在逻辑上可以表示为连接： 例如选择价格=（params.strike-asset.spot）*f

我使用的是JavaReactor核心，我有一个反应式的对象。对于Flux的每个对象，我需要进行外部查询，为每个输入返回一个不同的对象。然后需要将新生成的与原始的压缩-因此2 Flux的项目必须同步并以相同的顺序生成。 我只是重复使用相同的流两次，如下所示： 这是正确的方法吗？如果发出错误，如何防止阶段跳过失败的迭代？

我试图开发以下代码，但它不起作用。我想使用apache Flink来延迟时间（在时间戳字段中指定的）与当前日期不同的事件。 样品： > 当前日期：2022-05-06 10:30 事件1[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-05-06 10:30”}-- 事件2[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-