KnowStreaming
KnowStreaming copied to clipboard
didi
一站式云原生实时流数据平台，通过0侵入、插件化构建企业级Kafka服务，极大降低操作、存储和管理实时流数据门槛
- [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 你是否希望来认领这个Bug。 「 Y / N 」 ### 环境信息 * KnowStreaming version : 3.2.0 * Operating System version : centos7.3 * Java version : jdk17 ###...
如题，具体如图： 
如题，具体如下图所示：  ```json { "size": 0, "query": { "bool": { "must": [{ "term": { "clusterPhyId": { "value": 1251 } } }, { "term": { "connectClusterId": { "value": 11201 } }...
###问题代码段 ``` // 当前ZK上的迁移信息 scala.collection.Map currentParts = kafkaZkClient.getReplicaAssignmentForTopics( proposedParts.keySet().map(elem -> elem.topic()).toSet() ); // 转为moveMap格式 scala.collection.mutable.Map moveMap = ReassignPartitionsCommand.calculateProposedMoveMap(new scala.collection.mutable.HashMap(), proposedParts, currentParts); // 对Topic进行限流 scala.collection.Map leaderThrottles = ReassignPartitionsCommand.calculateLeaderThrottles(moveMap); scala.collection.Map followerThrottles =...
- [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 你是否希望来认领这个Bug。 「 Y / N 」 ### 环境信息 * KnowStreaming version : 0.3.2 * Operating System version : Macos11.6 * Java version : 10.0.2 ###...
- [ ] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 你是否希望来认领这个Bug。 「 Y / N 」 ### 环境信息 * KnowStreaming version : xxx * Operating System version : xxx * Java version : xxx...
- [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 你是否希望来认领这个Bug。 「 Y / N 」 ### 环境信息 * KnowStreaming version : 3.3.0 * Operating System version : xxx * Java version : xxx ###...
- [x] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 ## 在这里提出你的问题   目前发现在topic overview里面看到的BytesIn，BytesOut取得好像是所有broker的avg平均值，怎么才能取sum值？
- [ ] 我已经在 [issues](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 ## 在这里提出你的问题 我部署的es服务是https的，但是配置文件中的es地址只有ip跟端口号，不支持配置https，导致服务无法正常连接es。
- [x] 我已经在 [[issues](https://github.com/didi/KnowStreaming/issues)](https://github.com/didi/KnowStreaming/issues) 搜索过相关问题了,并没有重复的。 ## 调用Knowstreaming的/metrics/prometheus接口获得的指标中断 我在使用Grafana+Prometheus调用Knowstreaming的指标接口/metrics/prometheus时，出现了调用接口数据中断的情况，但是查看Knowstreaming上的相关Dashboard并未有中断的情况。 在这个[ISSUE 688](https://github.com/didi/KnowStreaming/pull/688)中，表示如果Knowstreaming页面上指标中断，会对缺失点进行补点吗？ 目前Knowstreaming提供的指标的中断情况一天会发生多次，单次持续几小时，是否调用Knowstreaming的/metrics/prometheus接口作为Kafka监控告警的数据源是不合适的？ 相关版本： - Knowstreaming-manager：0.7.0 - Knowstreaming-ui：0.7.0 - Prometheus：v2.22.2 - Grafana：v9.3.6 ### 场景1： Knowstreaming中只存在一个Kafka集群时，Grafana隔几个小时会没有监控数据，在NoData状态下手动curl /metrics/prometheus，接口内容中不存在相关指标。   ### 场景2： Knowstreaming中存在两个Kafka集群时，Grafana展示的两个集群的监控数据的NoData情况在Dashboard上是互斥的。 ...
