- 8月 04, 2022
-
-
由 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 创作于
-
由 Alok Thatikunta 创作于
This PR fixes a buggy log statement. ```java leaderEpoch = partitionState.leaderEpoch stateChangeLogger.info(s"Leader $topicPartition with...Previous leader epoch was $leaderEpoch.") ``` In https://github.com/confluentinc/ce-kafka/pull/6484 we assign the `partitionEpoch` before the log statement. This causes us to incorrectly print the older leader epoch value like ``` Jul 29, 2022 @ 17:50:24.246 | pkc-rrn31 | kafka-0 | [Broker id=0] Leader lkc-po2po_logrepo_gpid_health-3 with topic id Some(vkRS2TRdQaWyu_VMzwqdrQ) starts at leader epoch 56 from offset 1389662011 with partition epoch 97, high watermark 1389662011, ISR [0,2], adding replicas [] and removing replicas []. Previous leader epoch was 56. ``` To fix this, we introduce a local variable to store the previous value I verified that this happens only in ce-kafka `makeLeader`, AK does it correctly https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/cluster/Partition.scala#L646 reviewer: @hachikuji
-
由 venkatteki 创作于
-
由 Chris Egerton 创作于
Cherrypick a33c234c01aa39bb6b9a8b8a98a6064443774700 KAFKA-10000: Per-connector offsets topics (#11781) Implements support for per-connector offsets topics as described in KIP-618. Reviewers: Luke Chen <showuon@gmail.com>, Tom Bentley <tbentley@redhat.com>
-
由 Suchi Amalapurapu 创作于
-
由 Chris Egerton 创作于
Cherrypick AK commit 9e8ef8bb and fix tests and refactor builder related changes in Worker
-
由 Suchi Amalapurapu 创作于
Cherrypick AK commit 6853d63e - Fix test failures related to producerConfigs and adminConfigs
-
由 Chris Egerton 创作于
-
由 Suchi Amalapurapu 创作于
-