Kafka DSL stream Spallow自定义标头
我使用stream.to(outputTopic)；方法处理消息。
我已经找到了这个任务，它仍然是打开的。https://issues.apache.org/jira/browse/kafka-5632？src=confmacro
共有1个答案
你的观察是正确的。在Kafka1.1之前，Kafka Streams删除记录头。
在（即将发布的）Kafka2.0中增加了记录头支持，允许使用处理器API读取和修改头（参见https://issues.apache.org/jira/browse/kafka-6850)。对于KAFKA-6850，如果使用DSL，记录头也将被保留（即自动转发）。
提到的问题KAFKA-5632是关于DSL级别的报头操作，这在Kafka2.0中仍然不支持。
-
目前,诸葛io的服务范围涵盖了企业内各项业务，除了用户行为指标外，还有很多结合业务场景的特有指标需要分析；如：注册率=注册成功人数/活跃用户数，分、秒之间的单位换算等。 因此，诸葛io平台中提供了基础指标之间的四则运算，可灵活定义符合业务场景的特有指标，并支持自定义指标的可视化分析，以及将指标添加到数据看板中进行持续的跟踪监测的功能。 一、有哪些常见应用场景 场景一 某音频APP，需要统计人均收听
-
问题内容： 我想知道是否/如何在PHP中将自定义标头添加到cURL HTTP请求。我正在尝试模拟iTunes如何捕获图片并使用以下非标准标头： 如何将这些标头添加到请求中？ 问题答案： http://www.php.net/manual/zh/function.curl- setopt.php
-
问题内容： 我正在构建一个实现HTML5音频标签的音乐播放器Web应用程序，但是希望它在所有浏览器中看起来都一样-是否可以定义我自己的自定义CSS？如何？ 问题答案： 当前尚无使用CSS设置HTML5 播放器样式的方法。相反，您可以不使用该属性，而使用Javascript实现自己的控件。如果您不想自己全部实现它们，建议您使用现有的主题化HTML5音频播放器
-
主要内容：自定义标签的语法,简单示例,tld标签库描述文件,自定义标签属性,自定义标签的标签体自定义标签就是用户（开发者）自己定义的标签。自定义标签可以让 JSP 页面中不含有 Java 代码，只含有 HTML 代码和部分标签，就能实现业务逻辑的调用。 自定义标签的优点如下： 减少 JSP 页面对脚本的需求和依赖性 将 JSP 页面和业务逻辑分开，增加了程序的可维护性 可重复调用相同的业务逻辑，增加了程序的可重用性 使用自定义标签步骤如下： 自定义标签实现类 编写 tld 标签库描述文件
-
我正在尝试创建一个自定义标签类型，该类型将包含一个“淡出”函数。这用于显示将闪烁然后隐藏的消息。 我正在使用Eclipse、SceneBuilder和Javafx。我不知道该怎么做，也不知道是否可能，但到目前为止，我已经做到了： 这显然行不通。 这是我第一次在一个文件中处理凌乱的代码（因此，我尝试将代码从版本1拉入一个新的“对象”，我可以在多个类中使用它）： 如果您有任何建议或帮助，我们将不胜感激
-
自定义标签是用户定义的JSP语言元素。当JSP页面包含一个自定义标签时将被转化为servlet，标签转化为对被 称为tag handler的对象的操作，即当servlet执行时Web container调用那些操作。 JSP标签扩展可以让你创建新的标签并且可以直接插入到一个JSP页面。 JSP 2.0规范中引入Simple Tag Handlers来编写这些自定义标记。 你可以继承SimpleTa
-
Kubernetes中不仅支持CPU、内存为指标的HPA，还支持自定义指标的HPA，例如QPS。 本文中使用的yaml文件见manifests/HPA。 设置自定义指标 kubernetes1.6 在kubernetes1.6集群中配置自定义指标的HPA的说明已废弃。 在设置定义指标HPA之前需要先进行如下配置： 将heapster的启动参数 --api-server 设置为 true 启用cus
-
问题内容： 我想为每个部分自定义标题。到目前为止，我已经实施了 这种方法。我想做的是获取每个部分的当前标题，然后将其添加为子视图。 到目前为止，我还无法完成。因为，我找不到任何东西来获取默认节头。第一个问题， 有什么方法可以获取默认节头 ？ 如果不可能，那么我需要创建一个容器视图，但这一次，我需要设置默认的背景颜色，阴影颜色等。因为，如果仔细看一下该节的标题，它已经被自定义了。 如何获取每个节标题