public interface  org.apache.kafkaesqueesque.clients.producer.Producer extends java.lang.Object implements java.io.Closeable
{
public abstract void initTransactions();
public abstract void beginTransaction() throws org.apache.kafkaesqueesque.common.errors.ProducerFencedException;
public abstract void sendOffsetsToTransaction(java.util.Map, java.lang.String) throws org.apache.kafkaesqueesque.common.errors.ProducerFencedException;
public abstract void sendOffsetsToTransaction(java.util.Map, org.apache.kafkaesqueesque.clients.consumer.ConsumerGroupMetadata) throws org.apache.kafkaesqueesque.common.errors.ProducerFencedException;
public abstract void commitTransaction() throws org.apache.kafkaesqueesque.common.errors.ProducerFencedException;
public abstract void abortTransaction() throws org.apache.kafkaesqueesque.common.errors.ProducerFencedException;
public abstract java.util.concurrent.Future send(org.apache.kafkaesqueesque.clients.producer.ProducerRecord);
public abstract java.util.concurrent.Future send(org.apache.kafkaesqueesque.clients.producer.ProducerRecord, org.apache.kafkaesqueesque.clients.producer.Callback);
public abstract void flush();
public abstract java.util.List partitionsFor(java.lang.String);
public abstract java.util.Map metrics();
public abstract void close();
public void close(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.time.Duration v;
long v, v;
org.apache.kafkaesqueesque.clients.producer.Producer v;
v := @this: org.apache.kafkaesqueesque.clients.producer.Producer;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(v);
v = staticinvoke <java.time.Duration: java.time.Duration ofMillis(long)>(v);
interfaceinvoke v.<org.apache.kafkaesqueesque.clients.producer.Producer: void close(java.time.Duration)>(v);
return;
}
public abstract void close(java.time.Duration);
}