public interface  org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor extends java.lang.Object
{
public java.nio.ByteBuffer subscriptionUserData(java.util.Set)
{
java.util.Set v;
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor;
v := @parameter: java.util.Set;
return null;
}
public abstract org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$GroupAssignment assign(org.apache.kafkaesque.common.Cluster, org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$GroupSubscription);
public void onAssignment(org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$Assignment, org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata)
{
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$Assignment v;
org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata v;
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor;
v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$Assignment;
v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata;
return;
}
public java.util.List supportedProtocols()
{
java.util.List v;
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$RebalanceProtocol v;
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor;
v = <org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$RebalanceProtocol: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor$RebalanceProtocol EAGER>;
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
return v;
}
public short version()
{
org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerPartitionAssignor;
return 0;
}
public abstract java.lang.String name();
}