- 8月 05, 2022
-
-
由 Aishwarya Gune 创作于
* Add system test for triggerEvenClusterLoad command
-
由 Vikas Singh 创作于
This change adds a resource optimization framework to SBC. First version of the framework only has a vanilla cpu detction class that does basic over/under utilization check and generate a metric that can be used to take action on it. Co-authored-by: Shubhankar Ranade <sranade@confluent.io>
- 8月 04, 2022
-
-
由 David Mao 创作于
Building the principal takes ~ 1% of CPU since this is invoked on every request. Another implication is that the Scope used for RBAC is tied to a MultiTenantPrincipal - if we rebuild a principal on every request, then we recompute hash each time. We use a separate authenticator on reauthentication - so this should be safe from a reauth perspective.
-
由 Daniel Gospodinow 创作于
Adjusting the log level to something less stressful.
-
由 Grace Chen 创作于
* Test PR builds tagging images * docker login * gradle properties * Try PR builds on semaphore instead * Empty push to trigger semaphore CI * Try with make build-docker * Re-add copying gradle properties * Use old make docker * Try removing extraneous secrets * nit * Return secrets * Push only on PR titles containing pr-image string * nit * Test commit to trigger image build * Point to PR title * Test no build when not in PR title
-
由 Aman Singh 创作于
* KAFKA-6945: KIP-373, allow users to create delegation token for others (#10738) Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com> Co-authored-by: Viktor Somogyi-Vass <viktorsomogyi@gmail.com>
-
由 kpatelatwork 创作于
* KGLOBAL-1775 Authenticate NetworkRegionId is allowed to talk to this cluster deleted as we will include this in the main PR * minor nits * minor compile issues * added unit tests for PlainSaslServer authenticate * initialize SaslServer only once as authenticate can be called many times during mechanisms like SCRAM * removed extra {} in logs * added Reconfigurable authenticate callback handle as that seems to be one decent way to to test the networkRegionId injection * used newConfigs instead of configs * removed ReconfigurableAuthenticateCallbackHandler based on review comments before embarking on a new approach to testing this * checkstyle issues * removed unused NetworkRegionId
-
由 Vikas Singh 创作于
* KAFKALESS-1261: Use newly added follower fetch rate metric This change updates the code to use follower fetch reate metric that was added to Kafka to capture the replication load that partition have from followers perspective. This change adds code that make the metric part of Metric Sample. The metric has not been used to populate cluster model or use to attribute the cpu to a replica. That will be done in future changes. Unit tests pass. The tests are generic so they test all metrics to be in sane state in all data-structures that we need.
-
由 Colin Patrick McCabe 创作于
* MINOR: convert some more junit tests to support KRaft Introduce TestUtils#waitUntilLeaderIsElectedOrChangedWithAdmin, a ZK-free alternative to TestUtils#waitUntilLeaderIsElectedOrChanged. Convert PlaintextProducerSendTest, SslProducerSendTest, TransactionsWithMaxInFlightOneTest, AddPartitionsToTxnRequestServerTest and KafkaMetricsReporterTest to support KRaft Reviewers: dengziming <dengziming1993@gmail.com>, David Arthur <mumrah@gmail.com> Conflicts: BaseProducerSendTest.scala: fix a minor conflict
-
Read and write access to the TreeMap in snapshots needs to be synchronized. Reviewers: David Arthur <mumrah@gmail.com>
-
由 Jason Gustafson 创作于
Updates relevant tests in `ReassignPartitionsIntegrationTest` for KRaft. We skip JBOD tests since it is not supported and we skip `AlterPartition` upgrade tests since they are not relevant. Reviewers: Kvicii <Karonazaba@gmail.com>, David Arthur <mumrah@gmail.com> Conflicts: in ReassignPartitionsIntegrationTest, the default values for some configurations were different in ce-kafka. Also, there were some additional ce-kafka-only tests that I had to annotate as ZK-specific.
-
由 Colin Patrick McCabe 创作于
Convert ProducerCompressionTest, MirrorMakerIntegrationTest, EdgeCaseRequestTest to kraft. Make it explicit that ServerShutdownTest#testControllerShutdownDuringSend is ZK-only. Reviewers: David Arthur <mumrah@gmail.com> Conflicts: ServerShutdownTest.scala: disable testNoCleanShutdownAfterFailedStartupDueToCorruptLogs in ZK mode due to CPKAFKA-8947, which appears to be a pre-existing problem.
-
由 Prabhash Kumar 创作于
-
由 Aman Singh 创作于
Added metrics for monitoring Kafka Management events Testing: Tested metrics by generating the respective events.
- 8月 03, 2022
-
-
由 Stanislav Kozlovski 创作于
-
由 andymg3 创作于
-
由 venkatteki 创作于
-
由 Suchi Amalapurapu 创作于
Address Yash Mayya's comments around duplicate tests in AbstractWorkerSourceTaskTest and WorkerSourceTaskTest
-
由 Aneesh Garg 创作于
Jira: https://confluentinc.atlassian.net/browse/KSECURITY-508 Upgrading netty version to 4.1.79.Final Upgrading netty tcnative version to 2.0.53.Final
-
由 Aneesh Garg 创作于
Jira: https://confluentinc.atlassian.net/browse/KSECURITY-540 Upgrading aws-java-sdk version to 1.12.268
-
由 Vikas Singh 创作于
* KAFKALESS-1261: Add fetch count metric at topic level In a previous PR #6715 we have added a broker level fetch metric so that we can know how much replication activity is going on at a broker. This change adds the same for the topic level. This is needed for SBC to be able to attribute cpu to a partition/replica on this broker. I spent some time thinking on now to test this, any idea for it is welcome. I couldn't find existing tests that do that for other similar metrics. The code was tested as part of SBCv2 PoC, but an automated test will probably be useful.
-
由 gbadoni 创作于
-
由 venkatteki 创作于
-
由 Chris Egerton 创作于
-