Lan Ding
Lan Ding
This PR add resources to store and handle consumer group config. [jira](https://issues.apache.org/jira/browse/KAFKA-14511) Changes include: - Adding GRUOP to resource type - Corresponding DYNAMIC consumer group configurations in resources. - Changes...
The patch adds `ConsumerGroupHeartbeat` and `ConsumerGroupDescribe` API to `AuthorizerIntegrationTest`.
Replace `singleton` with `Set.of` in the SubscriptionStateTest.
Move DelayedRemoteFetch to the storage module and rewrite it to java.
Introduce Topic ID in existing OffsetFetch API, the patch only contains the client side changes.
1. Enabled ConfigCommand#validatePropsKey to support the `$` symbol. 2. Added UT and IT for the change. Reviewers: Chia-Ping Tsai
Move KRaftClusterTest from core module to server module. Rewrite - testCreateClusterAndCreateListDeleteTopic - testCreateClusterAndCreateAndManyTopics - testClientQuotas - testDefaultClientQuotas - testCreateClusterWithAdvertisedPortZero - testCreateClusterWithAdvertisedHostAndPortDifferentFromSocketServer - testUnregisterBroker
See https://github.com/apache/kafka/pull/20614#pullrequestreview-3379156676 Refactor nullable types as a subclass of non-nullable types.