- 7月 28, 2022
- 7月 20, 2022
-
-
由 Sanjana Kaundinya 创作于
-
由 Niket 创作于
Adding the implementation for `BeginShutdownControllerHandleAdapterHTTP::generateRollableStatus` on KRaft Controllers to check the quorum health and determine if the quorum would deplete if a node was rolled. The status is generated based on the amount of offset lag voters have compared to the node with the highest offset. If there is atleast one voter that is considered lagging, then the API claims the quorum is not roll-able.
-
由 Sushant Mahajan 创作于
- 7月 19, 2022
-
-
由 Rajini Sivaram 创作于
This implements the AdminAPI portion of KIP-709: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=173084258 . The request/response protocol changes were implemented in 3.0.0. A new batched API has been introduced to list consumer offsets for different groups. For brokers older than 3.0.0, separate requests are sent for each group. Co-authored-by:
Sanjana Kaundinya <skaundinya@gmail.com> Co-authored-by:
Rajini Sivaram <rajinisivaram@googlemail.com> Co-authored-by:
David Jacot <djacot@confluent.io> Reviewers: David Jacot <djacot@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>
-
由 Daniel Gospodinow 创作于
Adding functionality to SBC that provides computation of even cluster load plans without them being executed, like a dry-run.
-
由 Raman Verma 创作于
Simplify InternalAdmin.topicConfigurations code by removing unneeded wrap/unwrap in Option
-
由 Lingnan Liu 创作于
* KAFKALESS-1254: Disable BrokerFailureDetectorTest.testLoadFailedBrokers * KAFKALESS-1254: Disable BrokerFailureDetectorTest.testPartialClusterFailure
-
由 Cyrus Vafadari 创作于
* CIAM-1518: KSQL modeled as a "cluster" for RBAC cloud * fix
-
由 Alyssa Huang 创作于
Cherry-pick from apache/kafka#12395, addresses CPKAFKA-8338 KRaft mode will not support writing messages with an older message format (2.8) since the min supported IBP is 3.0 for KRaft. Testing support for reading older message formats will be covered by https://issues.apache.org/jira/browse/KAFKA-14056. Reviewers: David Jacot <djacot@confluent.io>
-
由 pberton 创作于
* Disabling failing Kafka test * Using ignore * Update upgrade_test.py * Updating jira link
-
由 pberton 创作于
* Disabled failed test CPKAFKA-6522 Disabling https://confluentinc.atlassian.net/browse/CPKAFKA-6522 as it never passed * Using ignore https://confluentinc.atlassian.net/browse/CPKAFKA-6522 * Updating jira link * Update network_degrade_test.py
-
由 tadsul 创作于
CIAM-2178 Split Role Def File for SDS into KSQL SDS and SR SDS
-
由 David Arthur 创作于
This was done to allow the ce-kafka-jmh job to complete. CPKAFKA-8893 was filed to undo this change
- 7月 18, 2022
-
-
由 Nikhil Srivastava 创作于
[SEC-3593] : [CP LDAP - Enable Configurable Case Sensitivity for Authorisation]
- 7月 16, 2022
-
-
由 Arvind Thirunarayanan 创作于
Dataplane audit logs need to publish the provider id along with the pool id.
-
由 kpatelatwork 创作于
KGLOBAL-1769: logging node identifier in the error message and making it consistent with other stop_node implementations (#6869)
-
由 Aishwarya 创作于
-
由 Yang Yu 创作于
When a broker loads log dir marked for deletion during startup, it creates a new MergedLog object and immediately adds it to the logsToBeDeleted queue. However, MergedLog.removeLogMetrics() is never called in this process. This leads to lingering log size metrics being reported. This PR prevents logs from registering metrics if it's marked as deleted.
-
由 David Arthur 创作于
-
由 Crispin Bernier 创作于
* fix flaky testCommitOffsetsMultipleGroupsAndMultipleBatches test * Increasing timeout * Revert some minor refactoring
- 7月 15, 2022