public interface  org.apache.kafkaesque.clients.producer.Partitioner extends java.lang.Object implements org.apache.kafkaesque.common.Configurable, java.io.Closeable
{
public abstract int partition(java.lang.String, java.lang.Object, byte[], java.lang.Object, byte[], org.apache.kafkaesque.common.Cluster);
public abstract void close();
public void onNewBatch(java.lang.String, org.apache.kafkaesque.common.Cluster, int)
{
org.apache.kafkaesque.clients.producer.Partitioner v;
int v;
org.apache.kafkaesque.common.Cluster v;
java.lang.String v;
v := @this: org.apache.kafkaesque.clients.producer.Partitioner;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.Cluster;
v := @parameter: int;
return;
}
}