KafkaProducerFactory		KafkaProducerFactory
	skipping to change at line 14		skipping to change at line 14
	protected io.dropwizard.kafka.serializer.SerializerFactory valueSerialize r;		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;
			protected io.dropwizard.util.Duration linger;
			protected io.dropwizard.util.Duration requestTimeout;
			protected boolean enableIdempotence;
	public io.dropwizard.kafka.KafkaProducerFactory();		public io.dropwizard.kafka.KafkaProducerFactory();
	public io.dropwizard.kafka.serializer.SerializerFactory getKeySerializer( );		public io.dropwizard.kafka.serializer.SerializerFactory getKeySerializer( );
	public void setKeySerializer(io.dropwizard.kafka.serializer.SerializerFac tory);		public void setKeySerializer(io.dropwizard.kafka.serializer.SerializerFac tory);
	public io.dropwizard.kafka.serializer.SerializerFactory getValueSerialize r();		public io.dropwizard.kafka.serializer.SerializerFactory getValueSerialize r();
	public void setValueSerializer(io.dropwizard.kafka.serializer.SerializerF actory);		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();
	skipping to change at line 37		skipping to change at line 40
	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 io.dropwizard.util.Duration getLinger();
			public void setLinger(io.dropwizard.util.Duration);
			public io.dropwizard.util.Duration getRequestTimeout();
			public void setRequestTimeout(io.dropwizard.util.Duration);
			public boolean isEnableIdempotence();
			public void setEnableIdempotence(boolean);
	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 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 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>);		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. 2 change blocks.
	0 lines changed or deleted		9 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/