KafkaProducerFactory		KafkaProducerFactory
	skipping to change at line 17		skipping to change at line 17
	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 linger;
	protected io.dropwizard.util.Duration requestTimeout;		protected io.dropwizard.util.Duration requestTimeout;
	protected boolean enableIdempotence;		protected boolean enableIdempotence;
			protected java.util.Optional<java.lang.String> transactionalId;
	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 46		skipping to change at line 47
	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 io.dropwizard.util.Duration getLinger();
	public void setLinger(io.dropwizard.util.Duration);		public void setLinger(io.dropwizard.util.Duration);
	public io.dropwizard.util.Duration getRequestTimeout();		public io.dropwizard.util.Duration getRequestTimeout();
	public void setRequestTimeout(io.dropwizard.util.Duration);		public void setRequestTimeout(io.dropwizard.util.Duration);
	public boolean isEnableIdempotence();		public boolean isEnableIdempotence();
	public void setEnableIdempotence(boolean);		public void setEnableIdempotence(boolean);
			public java.util.Optional<java.lang.String> getTransactionalId();
			public void setTransactionalId(java.util.Optional<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 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		3 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/