KafkaConsumerFactory		KafkaConsumerFactory
	Compiled from "KafkaConsumerFactory.java"		Compiled from "KafkaConsumerFactory.java"
	public abstract class io.dropwizard.kafka.KafkaConsumerFactory<K, V> extend s io.dropwizard.kafka.KafkaClientFactory implements io.dropwizard.jackson.D iscoverable {		public abstract class io.dropwizard.kafka.KafkaConsumerFactory<K, V> extend s io.dropwizard.kafka.KafkaClientFactory implements io.dropwizard.jackson.D iscoverable {
	protected java.lang.String consumerGroupId;		protected java.lang.String consumerGroupId;
	protected java.lang.String keyDeserializerClass;		protected io.dropwizard.kafka.deserializer.DeserializerFactory keyDeseria
	protected java.lang.String valueDeserializerClass;		lizer;
			protected io.dropwizard.kafka.deserializer.DeserializerFactory valueDeser
			ializer;
	protected boolean autoCommitEnabled;		protected boolean autoCommitEnabled;
	protected io.dropwizard.util.Duration autoCommitInterval;		protected io.dropwizard.util.Duration autoCommitInterval;
	protected int sendBufferBytes;		protected int sendBufferBytes;
	protected int receiveBufferBytes;		protected int receiveBufferBytes;
	protected int maxPollRecords;		protected int maxPollRecords;
	protected io.dropwizard.util.Duration maxPollInterval;		protected io.dropwizard.util.Duration maxPollInterval;
	public io.dropwizard.kafka.KafkaConsumerFactory();		public io.dropwizard.kafka.KafkaConsumerFactory();
	public java.lang.String getConsumerGroupId();		public java.lang.String getConsumerGroupId();
	public void setConsumerGroupId(java.lang.String);		public void setConsumerGroupId(java.lang.String);
	public java.lang.String getKeyDeserializerClass();		public io.dropwizard.kafka.deserializer.DeserializerFactory getKeyDeseria
	public void setKeyDeserializerClass(java.lang.String);		lizer();
			public void setKeyDeserializer(io.dropwizard.kafka.deserializer.Deseriali
			zerFactory);
			public io.dropwizard.kafka.deserializer.DeserializerFactory getValueDeser
			ializer();
			public void setValueDeserializer(io.dropwizard.kafka.deserializer.Deseria
			lizerFactory);
	public boolean isAutoCommitEnabled();		public boolean isAutoCommitEnabled();
	public void setAutoCommitEnabled(boolean);		public void setAutoCommitEnabled(boolean);
	public io.dropwizard.util.Duration getAutoCommitInterval();		public io.dropwizard.util.Duration getAutoCommitInterval();
	public void setAutoCommitInterval(io.dropwizard.util.Duration);		public void setAutoCommitInterval(io.dropwizard.util.Duration);
	public int getSendBufferBytes();		public int getSendBufferBytes();
	public void setSendBufferBytes(int);		public void setSendBufferBytes(int);
	public int getReceiveBufferBytes();		public int getReceiveBufferBytes();
	public void setReceiveBufferBytes(int);		public void setReceiveBufferBytes(int);
	public int getMaxPollRecords();		public int getMaxPollRecords();
	public void setMaxPollRecords(int);		public void setMaxPollRecords(int);
	public io.dropwizard.util.Duration getMaxPollInterval();		public io.dropwizard.util.Duration getMaxPollInterval();
	public void setMaxPollInterval(io.dropwizard.util.Duration);		public void setMaxPollInterval(io.dropwizard.util.Duration);
	public java.lang.String getValueDeserializerClass();
	public void setValueDeserializerClass(java.lang.String);
	protected java.util.Map<java.lang.String, java.lang.Object> createBaseKaf kaConfigurations();		protected java.util.Map<java.lang.String, java.lang.Object> createBaseKaf kaConfigurations();
			protected org.apache.kafka.clients.consumer.Consumer<K, V> buildConsumer( java.util.Map<java.lang.String, java.lang.Object>);
	protected void registerHealthCheck(com.codahale.metrics.health.HealthChec kRegistry, org.apache.kafka.clients.consumer.Consumer<K, V>);		protected void registerHealthCheck(com.codahale.metrics.health.HealthChec kRegistry, org.apache.kafka.clients.consumer.Consumer<K, V>);
			protected void manageConsumer(io.dropwizard.lifecycle.setup.LifecycleEnvi ronment, org.apache.kafka.clients.consumer.Consumer<K, V>);
	public org.apache.kafka.clients.consumer.Consumer<K, V> build(io.dropwiza rd.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Health CheckRegistry, brave.Tracing, org.apache.kafka.clients.consumer.ConsumerReb alanceListener);		public org.apache.kafka.clients.consumer.Consumer<K, V> build(io.dropwiza rd.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Health CheckRegistry, brave.Tracing, org.apache.kafka.clients.consumer.ConsumerReb alanceListener);
	public abstract org.apache.kafka.clients.consumer.Consumer<K, V> build(io .dropwizard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.heal th.HealthCheckRegistry, brave.Tracing, org.apache.kafka.clients.consumer.Co nsumerRebalanceListener, java.util.Map<java.lang.String, java.lang.Object>) ;		public abstract org.apache.kafka.clients.consumer.Consumer<K, V> build(io .dropwizard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.heal th.HealthCheckRegistry, brave.Tracing, org.apache.kafka.clients.consumer.Co nsumerRebalanceListener, java.util.Map<java.lang.String, java.lang.Object>) ;
	protected io.dropwizard.lifecycle.Managed createKafkaConsumerManager(org. apache.kafka.clients.consumer.Consumer);
	}		}
End of changes. 6 change blocks.
	7 lines changed or deleted		14 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/