Flink 1.15中是否有结合KafkaSource和ThrottleEditor的方法？
关于速率限制/限制Kafka消费者，有很多老话题
- 如何在flink上使用Ratimiter？
- 动态油门闪烁Kafka源
- 等等
但是它们都不能在案例1.15中使用：
KafkaFetcher不公开emitRecord- 现在它驻留在
KafkaRecordEmitter中
- KafkaSource是首选方法
所以，我的问题是，是否有必要将ThrottleEditor与KafkaSource结合起来？
- 现在它驻留在
共有1个答案
您不应该在主处理线程中应用速率限制，因为这会阻止检查点。您应该做的是在反序列化模式中应用速率限制。
您可以在反序列化模式的打开方法中设置速率限制器，并在反序列化方法中获取它。（但我会使用Guava RateLimitor，而不是节流迭代器。）
-
问题内容： 在SQL I中，（不幸的）我经常不得不使用“ ”条件，因为数据库违反了几乎所有的规范化规则。我现在无法更改。但这与问题无关。 此外，我经常使用条件来提高SQL语句的可读性和灵活性。 有没有可能在不编写复杂的子选择的情况下将这两件事结合起来的方法？ 我想要一些简单而不是这样的东西： 我在这里使用SQl Server和Oracle，但是我很感兴趣是否可以在任何RDBMS中实现。 问题答案：
-
问题内容： 因此，我在大学期间正在学习有关HTML列表的知识，这位教授说与其他标记（如和）一起没有结尾标记。那是正确的吗？因为最后我看到了很多使用tag的模板/主题，还有许多网站也教您存在，所以我不确定该相信谁以及正确的使用方式是什么？ 我问这个问题的原因是因为上次我们了解了标记，他说，当您将鼠标悬停在该属性上时，该属性会为您提供一个显示在图像上方的文本，当我在此处询问该属性时，它仅是替换图像的替
-
我知道，我可能可以用SFINAE和函数重载单独做到这一点。但是，对于像这样的情况，使用SFINAE是一种矫枉过正的做法。 所以我想知道是否有干净的方法来混合模板专业化和sfinae。
-
问题内容： 有时，我只想为条目列表执行一个函数-例如： 有时我需要这些东西来进行模块初始化，所以我不想在全局名称空间中占用x之类的空间。一种解决方案是将map与lambda一起使用： 但这当然会创建一个不错的列表[None，None，…]，所以我的问题是，是否存在没有返回列表的类似函数-因为我只是不需要它。 （当然，我也可以使用_x，因此不会留下可见的轮廓线-但地图解决方案看起来很整洁…） 问题答
-
问题内容： 我使用滑翔到一些图像加载 异步 到一些我的S，我知道它能够处理图像像或者因为它可以处理。 据我所知，加载这两种图像的方式有所不同。喜欢： 加载“正常”图像 加载SVG 而且，如果我尝试使用第一种方法加载SVG，它将无法正常工作。如果我尝试使用第二种方法加载PNG或JPG，它也将无法正常工作。 是否有使用Glide加载两种图像类型的通用方法？ 我从中获取这些图像的服务器在下载之前不会告诉
-
在结构中相同类型的连续成员之间的指针算术曾经是一种常见做法，而指针算术仅在数组中有效。在C中，它将是显式的未定义行为，因为数组只能由声明或新表达式创建。但是C语言将数组定义为连续分配的非空对象集，具有特定的成员对象类型，称为元素类型。（N1570 草案为 C11，6.2.5 类型 §20）。因此，如果我们可以确保成员是连续的（意味着它们之间没有填充），那么将其视为数组可能是合法的。 下面是一个简化