客户端限流console.

This commit is contained in:
许晓东
2023-01-02 21:28:47 +08:00
parent daf77290da
commit d5102f626c

View File

@@ -17,7 +17,7 @@ public class ClientQuotaConsoleTest {
void testGetClientQuotasConfigs() {
ClientQuotaConsole console = new ClientQuotaConsole(new KafkaConfig());
ContextConfig config = new ContextConfig();
config.setBootstrapServer("10.1.18.222:9092");
config.setBootstrapServer("127.0.0.1:9092");
ContextConfigHolder.CONTEXT_CONFIG.set(config);
Map<ClientQuotaEntity, Map<String, Object>> configs = console.getClientQuotasConfigs(Arrays.asList(ConfigType.User()), Arrays.asList());
configs.forEach((k, v) -> {