@Test public void getAdminProperties_propagateMetrics_defaultClusterId() { Properties properties = new Properties(); KafkaRestConfig config = new KafkaRestConfig(properties); Properties adminProperties = config.getAdminProperties(); assertEquals(KAFKA_REST_RESOURCE_CLUSTER_ID_DEFAULT, adminProperties.get(context_config(RESOURCE_LABEL_CLUSTER_ID))); }
public Properties getAdminProperties() { Properties adminProps = new Properties(); addTelemetryReporterProperties(adminProps); addPropertiesWithPrefix("client.", adminProps); addPropertiesWithPrefix("admin.", adminProps); return adminProps; }
KafkaRestConfig extends RestConfig { public Properties getAdminProperties() { Properties adminProps = new Properties(); addTelemetryReporterProperties(adminProps); addPropertiesWithPrefix("client.", adminProps); addPropertiesWithPrefix("admin.", adminProps); return adminProps; } }
KafkaRestConfig extends RestConfig { public Properties getAdminProperties() { Properties adminProps = new Properties(); addTelemetryReporterProperties(adminProps); addPropertiesWithPrefix("client.", adminProps); addPropertiesWithPrefix("admin.", adminProps); return adminProps; } KafkaRestConfig();  KafkaRestConfig(String propsFile);  KafkaRestConfig(Properties props);  KafkaRestConfig(Properties props, Time time);  KafkaRestConfig(ConfigDef configDef, Properties props, Time time); }
KafkaRestConfig extends RestConfig { public Properties getAdminProperties() { Properties adminProps = new Properties(); addTelemetryReporterProperties(adminProps); addPropertiesWithPrefix("client.", adminProps); addPropertiesWithPrefix("admin.", adminProps); return adminProps; } KafkaRestConfig();  KafkaRestConfig(String propsFile);  KafkaRestConfig(Properties props);  KafkaRestConfig(Properties props, Time time);  KafkaRestConfig(ConfigDef configDef, Properties props, Time time); Time getTime(); Properties getOriginalProperties(); Properties getProducerProperties(); Properties getConsumerProperties(); Properties getAdminProperties(); boolean isV2ApiEnabled(); boolean isV3ApiEnabled(); void addTelemetryReporterProperties(Properties props); @Override RestMetricsContext getMetricsContext(); int consumerPort(String scheme); static KafkaRestConfig newConsumerConfig(KafkaRestConfig config,
                                               ConsumerInstanceConfig instanceConfig
  ); static void main(String[] args); }
KafkaRestConfig extends RestConfig { public Properties getAdminProperties() { Properties adminProps = new Properties(); addTelemetryReporterProperties(adminProps); addPropertiesWithPrefix("client.", adminProps); addPropertiesWithPrefix("admin.", adminProps); return adminProps; } KafkaRestConfig();  KafkaRestConfig(String propsFile);  KafkaRestConfig(Properties props);  KafkaRestConfig(Properties props, Time time);  KafkaRestConfig(ConfigDef configDef, Properties props, Time time); Time getTime(); Properties getOriginalProperties(); Properties getProducerProperties(); Properties getConsumerProperties(); Properties getAdminProperties(); boolean isV2ApiEnabled(); boolean isV3ApiEnabled(); void addTelemetryReporterProperties(Properties props); @Override RestMetricsContext getMetricsContext(); int consumerPort(String scheme); static KafkaRestConfig newConsumerConfig(KafkaRestConfig config,
                                               ConsumerInstanceConfig instanceConfig
  ); static void main(String[] args); static final String TELEMETRY_PREFIX; static final String ID_CONFIG; static final String ID_DEFAULT; static final String MAX_POLL_RECORDS_CONFIG; static final String MAX_POLL_RECORDS_VALUE; static final String HOST_NAME_CONFIG; static final String HOST_NAME_DEFAULT; static final String ADVERTISED_LISTENERS_CONFIG; static final String CONSUMER_MAX_THREADS_CONFIG; static final String CONSUMER_MAX_THREADS_DEFAULT; static final String ZOOKEEPER_CONNECT_CONFIG; static final String ZOOKEEPER_CONNECT_DEFAULT; static final String BOOTSTRAP_SERVERS_CONFIG; static final String BOOTSTRAP_SERVERS_DEFAULT; static final String SCHEMA_REGISTRY_URL_CONFIG; static final String PROXY_FETCH_MIN_BYTES_CONFIG; static final ConfigDef.Range PROXY_FETCH_MIN_BYTES_VALIDATOR; static final String PRODUCER_THREADS_CONFIG; static final String PRODUCER_THREADS_DEFAULT; static final String CONSUMER_ITERATOR_TIMEOUT_MS_CONFIG; static final String CONSUMER_ITERATOR_TIMEOUT_MS_DEFAULT; static final String CONSUMER_ITERATOR_BACKOFF_MS_CONFIG; static final String CONSUMER_ITERATOR_BACKOFF_MS_DEFAULT; static final String CONSUMER_REQUEST_TIMEOUT_MS_CONFIG; static final String CONSUMER_REQUEST_TIMEOUT_MS_DEFAULT; static final String CONSUMER_REQUEST_MAX_BYTES_CONFIG; static final long CONSUMER_REQUEST_MAX_BYTES_DEFAULT; static final String CONSUMER_INSTANCE_TIMEOUT_MS_CONFIG; static final String CONSUMER_INSTANCE_TIMEOUT_MS_DEFAULT; static final String SIMPLE_CONSUMER_MAX_POOL_SIZE_CONFIG; static final String SIMPLE_CONSUMER_MAX_POOL_SIZE_DEFAULT; static final String SIMPLE_CONSUMER_POOL_TIMEOUT_MS_CONFIG; static final String SIMPLE_CONSUMER_POOL_TIMEOUT_MS_DEFAULT; static final String KAFKACLIENT_ZK_SESSION_TIMEOUT_MS_CONFIG; static final String KAFKACLIENT_TIMEOUT_CONFIG; static final String KAFKACLIENT_INIT_TIMEOUT_CONFIG; static final String ZOOKEEPER_SET_ACL_CONFIG; static final String KAFKACLIENT_SECURITY_PROTOCOL_CONFIG; static final String KAFKACLIENT_SSL_TRUSTSTORE_LOCATION_CONFIG; static final String KAFKACLIENT_SSL_TRUSTSTORE_PASSWORD_CONFIG; static final String KAFKACLIENT_SSL_KEYSTORE_LOCATION_CONFIG; static final String KAFKACLIENT_SSL_TRUSTSTORE_TYPE_CONFIG; static final String KAFKACLIENT_SSL_TRUSTMANAGER_ALGORITHM_CONFIG; static final String KAFKACLIENT_SSL_KEYSTORE_PASSWORD_CONFIG; static final String KAFKACLIENT_SSL_KEYSTORE_TYPE_CONFIG; static final String KAFKACLIENT_SSL_KEYMANAGER_ALGORITHM_CONFIG; static final String KAFKACLIENT_SSL_KEY_PASSWORD_CONFIG; static final String KAFKACLIENT_SSL_ENABLED_PROTOCOLS_CONFIG; static final String KAFKACLIENT_SSL_PROTOCOL_CONFIG; static final String KAFKACLIENT_SSL_PROVIDER_CONFIG; static final String KAFKACLIENT_SSL_CIPHER_SUITES_CONFIG; static final String KAFKACLIENT_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_SERVICE_NAME_CONFIG; static final String KAFKACLIENT_SASL_MECHANISM_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_KINIT_CMD_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_JITTER_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_CONFIG; static final String KAFKA_REST_RESOURCE_EXTENSION_CONFIG; static final String KAFKACLIENT_SASL_KERBEROS_SERVICE_NAME_DOC; static final String KAFKACLIENT_SASL_MECHANISM_DOC; static final String KAFKACLIENT_SASL_KERBEROS_KINIT_CMD_DOC; static final String KAFKACLIENT_SASL_KERBEROS_MIN_TIME_BEFORE_RELOGIN_DOC; static final String KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_JITTER_DOC; static final String KAFKACLIENT_SASL_KERBEROS_TICKET_RENEW_WINDOW_FACTOR_DOC; static final String CRN_AUTHORITY_CONFIG; static final String API_V2_ENABLE_CONFIG; static final String API_V3_ENABLE_CONFIG; static final String HTTPS; static final String HTTP; }