- 7月 30, 2022
-
-
由 David Mao 创作于
Embedded KRest uses percentiles for latency and calls sensor.add(CompoundStat) for probably every request see: https://github.com/ehumber/kafka-rest/blob/c900b9b0dfb72c7cdd09c451cb6913eadd452c1a/kafka-rest/src/main/java/io/confluent/kafkarest/resources/v3/ProducerMetrics.java#L253 Strangely this is not idempotent and causes a memory leak.
-
由 chern 创作于
This happens when cluster link prefix is used. Also rename mirrorTopic to sourceTopic in MirrorTopicDescription to avoid confusion.
- 7月 29, 2022
-
-
由 fred zheng 创作于
enhance clm system test to support kraft
-
由 David Mao 创作于
-
由 Rajini Sivaram 创作于
Reviewers: Nikhil Bhatia <rite2nikhil@gmail.com>
-
由 k-raina 创作于
* Fix flaky test in RbacSbcIntegrationTest
-
由 Chris Johnson 创作于
-
由 Keahooi Hung 创作于
-
由 Calvin Liu 创作于
-
由 Ron Dagostino 创作于
-
由 Vikas Singh 创作于
* KAFKALESS-1216: Add ReplicaEntity and ReplicaMetricSample classes This change adds a ReplicaMetricSample and ReplicaEntity class that can be used to capture replica level metrics. This is very simlar to the existing PartitionMetricSample/PartitionEntity and BrokerMetricSample/BrokerEntity clases. Added a test to make sure ser/deser works (we may take that out along with SampleStore later)
-
由 Yang Yu 创作于
When Kibosh removes storage fault, there seems to be cases where the fault is not removed in a timely manner. This pr forces recreate of the log dir to ensure storage fault is removed.
-
由 Lingnan Liu 创作于
* KAFKALESS-1167: Configuration of incremental balancing * Use Double.compare * Use constants from BalancerConfigs * Add Incremental balancing default value as a constant * Add config validations * Factor out code for dynamic config * Better documentation, removed default values from doc * Update clients/src/main/java/org/apache/kafka/common/config/internals/BalancerConfigs.java Co-authored-by: Stanislav Kozlovski <stanislav_kozlovski@outlook.com> Co-authored-by: Stanislav Kozlovski <stanislav_kozlovski@outlook.com>
-
- 7月 28, 2022
-
-
由 Marcus Greer 创作于
-
由 Aneesh Garg 创作于
Jira: https://confluentinc.atlassian.net/browse/CIAM-1530 Description: To debug data plane auth issues, it handy / part of runbooks to log onto a Kafka node and dump/inspect the auth topic via the kafka console consumer. Header of messages from topic _confluent-metadata-auth is in protobuff format. This PR aims at making the dump more readable by making use of MessageFormatter.
-
由 Arvind Thirunarayanan 创作于
-
由 Bob Barrett 创作于
-
由 Feng Min 创作于
-
由 Vikas Singh 创作于
* KAFKALESS-1217: Move TopicPartition to PartitionInfo SBC metric collection code uses TopicPartition class to keep track of topic metrics. However this class only contains partition information and there is no replica information. The PartitionInfo class instead has all the replica and ISR information. This is also the class that is present in the Cluster class that we get from cluster metadata. This change updates the code to use PartitionInfo instead of TopicPartition so that replica level metrics can be captured. This is simple refactoring, all tests pass.
-
由 kpatelatwork 创作于
* KGLOBAL-1727 : add NetworkRegionId tag to CL SaslAuthenticate request if available * fixed broken test * added more tests * minor cleanups * minor cleanups * added debug logs * added tests for request callback * fixing broken test * bumped version in tests for SASL_AUTHENTICATE * moved back version to 2 and fixed review comments * added verify that no tags are added and also fixed broken test * fixed minor indents and import order issues * moved traffic config to Confluent config
-
由 Arvind Thirunarayanan 创作于