- 8月 04, 2022
-
-
由 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 创作于
-
由 Suchi Amalapurapu 创作于
-
- 8月 02, 2022
-
-
由 Chris Egerton 创作于
-
由 Suchi Amalapurapu 创作于
Cherrypick AK commit a110f1fe - Merge header configs along with producer, consumer and admin configs
-
由 Alok Thatikunta 创作于
As part of AK/ce merge we introduced a duplicate dependency. This PR removes it Related commit from AK https://github.com/confluentinc/ce-kafka/commit/6f2cb60ef6a6512d48a7dbfd0c9adc0f1cc3fa11 merged as part of https://github.com/confluentinc/ce-kafka/pull/3529 reviewers: @ijuma
-
由 Chris Egerton 创作于
-
由 Daniel Gospodinow 创作于
System tests for computing even cluster load plans.
-