KafkaProducerFactory		KafkaProducerFactory
	Compiled from "KafkaProducerFactory.java"		Compiled from "KafkaProducerFactory.java"
	public abstract class io.dropwizard.kafka.KafkaProducerFactory<K, V> extend s io.dropwizard.kafka.KafkaClientFactory implements io.dropwizard.jackson.D iscoverable {		public abstract class io.dropwizard.kafka.KafkaProducerFactory<K, V> extend s io.dropwizard.kafka.KafkaClientFactory implements io.dropwizard.jackson.D iscoverable {
	protected java.lang.String keySerializerClass;		protected io.dropwizard.kafka.serializer.SerializerFactory keySerializer;
	protected java.lang.String valueSerializerClass;		protected io.dropwizard.kafka.serializer.SerializerFactory valueSerialize
			r;
	protected java.util.Optional<java.lang.String> acks;		protected java.util.Optional<java.lang.String> acks;
	protected java.util.Optional<java.lang.String> retries;		protected java.util.Optional<java.lang.String> retries;
	protected java.util.Optional<java.lang.Integer> maxInFlightRequestsPerCon nection;		protected java.util.Optional<java.lang.Integer> maxInFlightRequestsPerCon nection;
	protected java.util.Optional<io.dropwizard.util.Duration> maxPollBlockTim e;		protected java.util.Optional<io.dropwizard.util.Duration> maxPollBlockTim e;
	protected java.lang.String compressionType;		protected java.lang.String compressionType;
	protected int sendBufferBytes;		protected int sendBufferBytes;
	protected int receiveBufferBytes;		protected int receiveBufferBytes;
	protected long bufferMemory;		protected long bufferMemory;
	protected int batchSize;		protected int batchSize;
	public io.dropwizard.kafka.KafkaProducerFactory();		public io.dropwizard.kafka.KafkaProducerFactory();
	public java.lang.String getKeySerializerClass();		public io.dropwizard.kafka.serializer.SerializerFactory getKeySerializer(
	public void setKeySerializerClass(java.lang.String);		);
			public void setKeySerializer(io.dropwizard.kafka.serializer.SerializerFac
			tory);
			public io.dropwizard.kafka.serializer.SerializerFactory getValueSerialize
			r();
			public void setValueSerializer(io.dropwizard.kafka.serializer.SerializerF
			actory);
	public java.util.Optional<java.lang.String> getAcks();		public java.util.Optional<java.lang.String> getAcks();
	public void setAcks(java.util.Optional<java.lang.String>);		public void setAcks(java.util.Optional<java.lang.String>);
	public java.util.Optional<java.lang.String> getRetries();		public java.util.Optional<java.lang.String> getRetries();
	public void setRetries(java.util.Optional<java.lang.String>);		public void setRetries(java.util.Optional<java.lang.String>);
	public java.util.Optional<java.lang.Integer> getMaxInFlightRequestsPerCon nection();		public java.util.Optional<java.lang.Integer> getMaxInFlightRequestsPerCon nection();
	public void setMaxInFlightRequestsPerConnection(java.util.Optional<java.l ang.Integer>);		public void setMaxInFlightRequestsPerConnection(java.util.Optional<java.l ang.Integer>);
	public java.util.Optional<io.dropwizard.util.Duration> getMaxPollBlockTim e();		public java.util.Optional<io.dropwizard.util.Duration> getMaxPollBlockTim e();
	public void setMaxPollBlockTime(java.util.Optional<io.dropwizard.util.Dur ation>);		public void setMaxPollBlockTime(java.util.Optional<io.dropwizard.util.Dur ation>);
	public java.lang.String getCompressionType();		public java.lang.String getCompressionType();
	public void setCompressionType(java.lang.String);		public void setCompressionType(java.lang.String);
	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 long getBufferMemory();		public long getBufferMemory();
	public void setBufferMemory(long);		public void setBufferMemory(long);
	public int getBatchSize();		public int getBatchSize();
	public void setBatchSize(int);		public void setBatchSize(int);
	public java.lang.String getValueSerializerClass();
	public void setValueSerializerClass(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 void registerProducerHealthCheck(com.codahale.metrics.health.He
			althCheckRegistry, org.apache.kafka.clients.producer.Producer<K, V>, java.u
			til.Collection<java.lang.String>);
			protected org.apache.kafka.clients.producer.Producer<K, V> buildProducer(
			java.util.Map<java.lang.String, java.lang.Object>);
			protected void manageProducer(io.dropwizard.lifecycle.setup.LifecycleEnvi
			ronment, org.apache.kafka.clients.producer.Producer<K, V>);
	public org.apache.kafka.clients.producer.Producer<K, V> build(io.dropwiza rd.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Health CheckRegistry, java.util.Collection<java.lang.String>, brave.Tracing);		public org.apache.kafka.clients.producer.Producer<K, V> build(io.dropwiza rd.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.health.Health CheckRegistry, java.util.Collection<java.lang.String>, brave.Tracing);
	public abstract org.apache.kafka.clients.producer.Producer<K, V> build(io .dropwizard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.heal th.HealthCheckRegistry, java.util.Collection<java.lang.String>, brave.Traci ng, java.util.Map<java.lang.String, java.lang.Object>);		public abstract org.apache.kafka.clients.producer.Producer<K, V> build(io .dropwizard.lifecycle.setup.LifecycleEnvironment, com.codahale.metrics.heal th.HealthCheckRegistry, java.util.Collection<java.lang.String>, brave.Traci ng, java.util.Map<java.lang.String, java.lang.Object>);
	}		}
End of changes. 4 change blocks.
	6 lines changed or deleted		18 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/