- 9月 30, 2022
-
-
-
由 Divij Vaidya 创作于
The test is failing intermittently because we do not wait for propagation of the altered config (LogRetentionTimeMillisProp) across all brokers before proceeding ahead with the test. This PR makes the following changes: 1. Wait for propagation of altered configuration to propagate to all brokers. 2. Use the existing `killBroker` utility method which waits for shutdown using `awaitshutdown`. 3. Improve code readability by using `TestUtils.incrementalAlterConfigs` to send alter config requests. Reviewers: Jason Gustafson <jason@confluent.io>
-
-
Reviewers: Ismael Juma <ismael@juma.me.uk>
-
-
Reviewers: David Arthur <mumrah@gmail.com>
-
-
由 LinShunKang 创作于
KAFKA-4852: Fix ByteBufferSerializer#serialize(String, ByteBuffer) not compatible with offsets (#12683) Reviewers: Guozhang Wang <wangguoz@gmail.com>
-
-
由 Colin P. McCabe 创作于
- 9月 29, 2022
-
-
由 Colin P. McCabe 创作于
-
由 Colin P. McCabe 创作于
-
-
由 Guozhang Wang 创作于
When a topology is paused / resumed, we also need to pause / resume its corresponding tasks inside state updater. Reviewers: Guozhang Wang <wangguoz@gmail.com>
-
- 9月 28, 2022
-
-
-
由 Chase Thomas 创作于
Reviewers: Jason Gustafson <jason@confluent.io>
-
- 9月 27, 2022
-
-
-
由 Orsák Maroš 创作于
-
-
由 Jason Gustafson 创作于
This patch adds a section in security.html about listener configuration. This includes the basics of how to define the security mapping of each listener as well as the configurations to control inter-cluster traffic. Reviewers: José Armando García Sancio <jsancio@users.noreply.github.com>, Luke Chen <showuon@gmail.com>
-
-
由 Jason Gustafson 创作于
Update a few cases in the documentation which do not make sense for KRaft. Reviewers: José Armando García Sancio <jsancio@users.noreply.github.com>
-
-
由 Bruno Cadonna 创作于
When the state updater only contains standby tasks and then a standby task is removed, an IllegalStateException is thrown because the changelog reader does not allow to switch to standby updating mode more than once in a row. This commit fixes this bug by checking that the removed task is an active one before trying to switch to standby updating mode. If the task to remove is a standby task then either we are already in standby updating mode and we should not switch to it again or we are not in standby updating mode which implies that there are still active tasks that would prevent us to switch to standby updating mode. Reviewer: Guozhang Wang <wangguoz@gmail.com>
-
-
Reviewers: Colin Patrick McCabe <cmccabe@apache.org>, Chase Thomas <forlack@users.noreply.github.com>
-
- 9月 26, 2022
-
-
- 9月 24, 2022
-
-
-
由 Ahmed Sobeh 创作于
This PR makes the following changes: * Moves the only test in StateRestorationIntegrationTest into RestoreIntegrationTest * Deletes StateRestorationIntegrationTest Reviewers: Guozhang Wang <wangguoz@gmail.com>
-
-
由 Colin Patrick McCabe 创作于
Previously, BrokerRegistration#toString sould throw an exception, terminating metadata replay, because the sorted() method is used on an entry set rather than a key set. Reviewers: David Arthur <mumrah@gmail.com>
-
-
由 Divij Vaidya 创作于
Reviewers: Chris Egerton <chrise@aiven.io>
-
- 9月 23, 2022
-
-
-
由 Kirk True 创作于
* KAFKA-13725: KIP-768 OAuth code mixes public and internal classes in same package Move classes into a sub-package of "internal" named "secured" that matches the layout more closely of the "unsecured" package. Replaces the concrete implementations in the former packages with sub-classes of the new package layout and marks them as deprecated. If anyone is already using the newer OAuth code, this should still work. * Fix checkstyle and spotbugs violations Co-authored-by: Kirk True <kirk@mustardgrain.com> Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
-
-
由 Justine Olshan 创作于
Make `producer.id.expiration.ms` a dynamic configuration as described in KIP-854. Reviewers: David Jacot <djacot@confluent.io>
-
-