Skip to content

Fix some metrics#70

Merged
Guozhang Wang (guozhangwang) merged 5 commits into
confluentinc:streamingfrom
guozhangwang:fixMetrics
Sep 22, 2015
Merged

Fix some metrics#70
Guozhang Wang (guozhangwang) merged 5 commits into
confluentinc:streamingfrom
guozhangwang:fixMetrics

Conversation

@guozhangwang

Copy link
Copy Markdown

ymatsuda

Also change the punctuate function to use clock time, and add the client-Id for metrics prefix.

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What happens to the thread names when multiple KafkaStreaming instances are running in the same JVM?

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good point, will change it back.

@ymatsuda

Copy link
Copy Markdown

lgtm

Guozhang Wang (guozhangwang) added a commit that referenced this pull request Sep 22, 2015
@guozhangwang Guozhang Wang (guozhangwang) merged commit e83d54b into confluentinc:streaming Sep 22, 2015
@guozhangwang Guozhang Wang (guozhangwang) deleted the fixMetrics branch October 7, 2016 21:45
José Armando García Sancio (jsancio) pushed a commit that referenced this pull request Sep 13, 2019
We use the existing CreateTopicPolicy to validate the request explicitly in AdminManager.scala

This is a temporary change until KIP-201 is implemented. It is being driven by developers outside of Confluent. There is no use to implement our own KIP-201 because we would have to use the AK one in time.
Andrew Egelhofer (andrewegel) pushed a commit that referenced this pull request Nov 16, 2021
List of commits from kafka-broker-plugins:

* Include all transitive dependencies in assembly (#71)
* Add OAuth LoginCallbackHandler for the Kafka server (#72)
* CPKAFKA-1593: Multi-tenant authorizer for CCloud (#66)
* CPKAFKA-1593: Integration tests for multi-tenant authorizer for CCloud (#67)
* CAAS-1960: Implement Phase 3.1 Metrics (#76)
* CAAS-1960: Add authenticated connections and authentication rate metrics per tenant (#77)
* Bump Confluent to 5.2.0-SNAPSHOT, Kafka to 2.2.0-SNAPSHOT
* Topic config constraints (#70)
* Remove redundant import in MultiTenantRequestContext (#79)
* 4.1.x to 5.0.x (#78)
* 5.0.x to 5.1.x (#82)
* CPKAFKA-1408: Add tenant throughput and request quota plugin (#68)
* Improve topic policy checks (#81)
* CPKAFKA-1410: Partition assignor to balance partitions at tenant level (#73)
* CPKAFKA-1694: Add partition throughput percentiles for monitoring (#84)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants