kafka streams 2.5.0不支持在reduce上命名？
您好，我需要为kafka streams中创建的内部/中间主题指定一个自定义名称。
但是，只有“*重新分区”主题会被重命名，而“聚合”主题不会被重命名。
kafka streams 2.5.0似乎不支持在reduce上命名？
我配置了它，但它不采取它...分组的采取命名
我需要为了能够很好地演示Azkarra流时浏览状态存储查询。
更新：您好，kafka社区，我知道，我使用的命名参数用于配置用于在拓扑中命名处理器的名称，但是是否有任何方法可以为中间主题（如kstream aggregate-…）提供自定义的、更可读的名称？谢谢
共有1个答案
应该可以命名所有处理器/商店/主题。
然而，并不总是清楚API是如何工作的——事实上，一些命名的参数“重叠”。这是一个众所周知的问题，没有很好的记录。我们需要在某个时候解决这个问题。
如果要命名变更日志主题，可以通过物化命名相应的存储，存储名称将被重新用于变更日志主题。
如果要命名重新分区主题，可以通过groupBy（）或groupByKey（）的Grouped参数传递名称。
-
但当我在命令行上运行该命令时,它会抛出以下错误： 我可以成功地运行其他的adb命令，我不知道aapt命令有什么问题。另外，我正在Windows7环境下进行开发。
-
我已经在我的Web API控制器上启用了CORS支持，它在https上运行良好，但在http上，我仍然收到请求的资源错误上存在的o“Access Control Allow Origin”头。 在WebApiConfig中，我使用以下行启用了cors： 我的控制器类是这样介绍的： 那么如何在http和https上启用CORS呢？ 在azure原始http日志上，创建一个调用时会出现以下行：
-
我正在使用以下代码片段创建一个chrome浏览器- 我在使用Chrome运行测试时遇到了一个错误。该错误显示在启动浏览器的地址栏下方： 您正在使用不受支持的命令行标志--忽略证书错误。稳定和安全将受到影响。 有没有简单的方法让这个消息消失？理想情况下，我想用ruby代码本身来做。
-
我想在一个特定的领域进行NER实验，即从意大利语的旅行优惠中提取位置名称。 到目前为止，我需要自己准备训练，所以我要把 在我的培训集中的一些报价中添加标签。 但在查看OpenNLP关于如何为NER进行培训的文档时，我最终遇到了几个问题： 1） 在定义开始/结束标记时，我可以自由使用标记中的任何名称（我在上面几行写了“某物”），或者是否有要绑定的限制集？ 2） 我注意到对培训工具的调用 将表示语言的
-
我想上传带有spring-boot和vue的文件。但是，我有一个错误“415:Unsupported MediaType”。 这是我的Spring启动控制器。 而且，这是我的vue代码。 我尝试，但遇到同样的错误。我该如何修复它？
-
DataSource 接口 不支持 timeout 相关操作 Connection 接口 不支持存储过程，函数，游标的操作 不支持执行 native SQL 不支持 savepoint 相关操作 不支持 Schema/Catalog 的操作 不支持自定义类型映射 Statement 和 PreparedStatement 接口 不支持返回多结果集的语句（即存储过程，非 SELECT 多条数据） 不