| KafkaAdminClientFactory | KafkaAdminClientFactory | |||
|---|---|---|---|---|
| skipping to change at line 21 | skipping to change at line 21 | |||
| protected io.dropwizard.util.Duration connectionMaxIdle; | protected io.dropwizard.util.Duration connectionMaxIdle; | |||
| protected io.dropwizard.util.Duration requestTimeout; | protected io.dropwizard.util.Duration requestTimeout; | |||
| protected io.dropwizard.util.Duration metadataMaxAge; | protected io.dropwizard.util.Duration metadataMaxAge; | |||
| protected java.lang.Integer sendBufferBytes; | protected java.lang.Integer sendBufferBytes; | |||
| protected java.lang.Integer receiveBufferBytes; | protected java.lang.Integer receiveBufferBytes; | |||
| protected java.util.List<java.lang.Class<? extends org.apache.kafka.commo n.metrics.MetricsReporter>> metricsReporters; | protected java.util.List<java.lang.Class<? extends org.apache.kafka.commo n.metrics.MetricsReporter>> metricsReporters; | |||
| protected java.lang.Integer metricsSamples; | protected java.lang.Integer metricsSamples; | |||
| protected io.dropwizard.util.Duration metricsSampleWindow; | protected io.dropwizard.util.Duration metricsSampleWindow; | |||
| protected org.apache.kafka.common.metrics.Sensor$RecordingLevel metricsRe cordingLevel; | protected org.apache.kafka.common.metrics.Sensor$RecordingLevel metricsRe cordingLevel; | |||
| protected io.dropwizard.kafka.security.SecurityFactory security; | protected io.dropwizard.kafka.security.SecurityFactory security; | |||
| protected boolean topicCreationEnabled; | ||||
| protected java.util.Set<io.dropwizard.kafka.KafkaTopicFactory> topics; | ||||
| public io.dropwizard.kafka.KafkaAdminClientFactory(); | public io.dropwizard.kafka.KafkaAdminClientFactory(); | |||
| public java.lang.String getName(); | public java.lang.String getName(); | |||
| public void setName(java.lang.String); | public void setName(java.lang.String); | |||
| public java.lang.String getClientId(); | public java.lang.String getClientId(); | |||
| public void setClientId(java.lang.String); | public void setClientId(java.lang.String); | |||
| public java.util.Set<java.lang.String> getBootstrapServers(); | public java.util.Set<java.lang.String> getBootstrapServers(); | |||
| public void setBootstrapServers(java.util.Set<java.lang.String>); | public void setBootstrapServers(java.util.Set<java.lang.String>); | |||
| public org.apache.kafka.clients.ClientDnsLookup getClientDnsLookup(); | public org.apache.kafka.clients.ClientDnsLookup getClientDnsLookup(); | |||
| public void setClientDnsLookup(org.apache.kafka.clients.ClientDnsLookup); | public void setClientDnsLookup(org.apache.kafka.clients.ClientDnsLookup); | |||
| public io.dropwizard.util.Duration getReconnectBackoff(); | public io.dropwizard.util.Duration getReconnectBackoff(); | |||
| skipping to change at line 58 | skipping to change at line 60 | |||
| public java.util.List<java.lang.Class<? extends org.apache.kafka.common.m etrics.MetricsReporter>> getMetricsReporters(); | public java.util.List<java.lang.Class<? extends org.apache.kafka.common.m etrics.MetricsReporter>> getMetricsReporters(); | |||
| public void setMetricsReporters(java.util.List<java.lang.Class<? extends org.apache.kafka.common.metrics.MetricsReporter>>); | public void setMetricsReporters(java.util.List<java.lang.Class<? extends org.apache.kafka.common.metrics.MetricsReporter>>); | |||
| public java.lang.Integer getMetricsSamples(); | public java.lang.Integer getMetricsSamples(); | |||
| public void setMetricsSamples(java.lang.Integer); | public void setMetricsSamples(java.lang.Integer); | |||
| public io.dropwizard.util.Duration getMetricsSampleWindow(); | public io.dropwizard.util.Duration getMetricsSampleWindow(); | |||
| public void setMetricsSampleWindow(io.dropwizard.util.Duration); | public void setMetricsSampleWindow(io.dropwizard.util.Duration); | |||
| public org.apache.kafka.common.metrics.Sensor$RecordingLevel getMetricsRe cordingLevel(); | public org.apache.kafka.common.metrics.Sensor$RecordingLevel getMetricsRe cordingLevel(); | |||
| public void setMetricsRecordingLevel(org.apache.kafka.common.metrics.Sens or$RecordingLevel); | public void setMetricsRecordingLevel(org.apache.kafka.common.metrics.Sens or$RecordingLevel); | |||
| public io.dropwizard.kafka.security.SecurityFactory getSecurity(); | public io.dropwizard.kafka.security.SecurityFactory getSecurity(); | |||
| public void setSecurity(io.dropwizard.kafka.security.SecurityFactory); | public void setSecurity(io.dropwizard.kafka.security.SecurityFactory); | |||
| public java.util.Set<io.dropwizard.kafka.KafkaTopicFactory> getTopics(); | ||||
| public java.lang.Boolean getTopicCreationEnabled(); | ||||
| public void setTopicCreationEnabled(boolean); | ||||
| protected org.apache.kafka.clients.admin.AdminClient buildAdminClient(jav a.util.Map<java.lang.String, java.lang.Object>); | protected org.apache.kafka.clients.admin.AdminClient buildAdminClient(jav a.util.Map<java.lang.String, java.lang.Object>); | |||
| protected void manageAdminClient(io.dropwizard.lifecycle.setup.LifecycleE nvironment, org.apache.kafka.clients.admin.AdminClient); | protected void manageAdminClient(io.dropwizard.lifecycle.setup.LifecycleE nvironment, org.apache.kafka.clients.admin.AdminClient); | |||
| protected void manageAdminClient(io.dropwizard.lifecycle.setup.LifecycleE nvironment, org.apache.kafka.clients.admin.AdminClient, java.util.Collectio n<org.apache.kafka.clients.admin.NewTopic>); | ||||
| protected void registerHealthCheck(com.codahale.metrics.health.HealthChec kRegistry, org.apache.kafka.clients.admin.AdminClient); | protected void registerHealthCheck(com.codahale.metrics.health.HealthChec kRegistry, org.apache.kafka.clients.admin.AdminClient); | |||
| public abstract org.apache.kafka.clients.admin.AdminClient build(com.coda | public abstract org.apache.kafka.clients.admin.AdminClient build(io.dropw | |||
| hale.metrics.health.HealthCheckRegistry, io.dropwizard.lifecycle.setup.Life | izard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Hea | |||
| cycleEnvironment, java.util.Map<java.lang.String, java.lang.Object>); | lthCheckRegistry, java.util.Map<java.lang.String, java.lang.Object>); | |||
| public abstract org.apache.kafka.clients.admin.AdminClient build(io.dropw | ||||
| izard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Hea | ||||
| lthCheckRegistry, java.util.Map<java.lang.String, java.lang.Object>, java.u | ||||
| til.Collection<org.apache.kafka.clients.admin.NewTopic>); | ||||
| } | } | |||
| End of changes. 4 change blocks. | ||||
| 3 lines changed or deleted | 13 lines changed or added | |||
This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/ | ||||