beardt commented on code in PR #13168:
URL: https://github.com/apache/kafka/pull/13168#discussion_r1107961671
##########
clients/src/test/java/org/apache/kafka/common/config/AbstractConfigTest.java:
##########
@@ -599,6 +624,31 @@ public TestConfig(Map<?, ?> props) {
}
}
+ private static class InterceptorTestConfig extends AbstractConfig {
+ private final int targetInterceptor = 3;
+ private static final ConfigDef CONFIG;
+ private static final String INTERCEPTOR_CLASSES_CONFIG_DOC = "A list
of classes to use as interceptors.";
+
+ public static final String INTERCEPTOR_CLASSES_CONFIG =
"interceptor.classes";
+ public static final String CLIENT_ID_CONFIG = "client.id";
+ public static final String BOOTSTRAP_SERVERS_CONFIG =
"bootstrap.servers";
+
+ static {
+ CONFIG = new ConfigDef().define(INTERCEPTOR_CLASSES_CONFIG,
+ Type.LIST,
+ Collections.emptyList(),
+ Importance.LOW,
+ INTERCEPTOR_CLASSES_CONFIG_DOC);
+ }
+ public InterceptorTestConfig(Map<?, ?> props) {
+ super(CONFIG, props);
+ }
+
+ public int getTargetInterceptor() {
+ return targetInterceptor;
+ }
+ }
Review Comment:
@C0urante No apologies necessary. I've reverted the code back to your
preference.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
