public interface  org.apache.kafkaesque.clients.admin.Admin extends java.lang.Object implements java.lang.AutoCloseable
{
public static org.apache.kafkaesque.clients.admin.Admin create(java.util.Properties)
{
java.util.Properties v;
org.apache.kafkaesque.clients.admin.AdminClientConfig v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient v;
v := @parameter: java.util.Properties;
v = new org.apache.kafkaesque.clients.admin.AdminClientConfig;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AdminClientConfig: void <init>(java.util.Map,boolean)>(v, 1);
v = staticinvoke <org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.admin.KafkaAdminClient createInternal(org.apache.kafkaesque.clients.admin.AdminClientConfig,org.apache.kafkaesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory)>(v, null);
return v;
}
public static org.apache.kafkaesque.clients.admin.Admin create(java.util.Map)
{
org.apache.kafkaesque.clients.admin.AdminClientConfig v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient v;
java.util.Map v;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AdminClientConfig;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AdminClientConfig: void <init>(java.util.Map,boolean)>(v, 1);
v = staticinvoke <org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.admin.KafkaAdminClient createInternal(org.apache.kafkaesque.clients.admin.AdminClientConfig,org.apache.kafkaesque.clients.admin.KafkaAdminClient$TimeoutProcessorFactory)>(v, null);
return v;
}
public void close()
{
java.util.concurrent.TimeUnit v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: void close(long,java.util.concurrent.TimeUnit)>(9223372036854775807L, v);
return;
}
public void close(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
java.time.Duration v;
long v, v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
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.kafkaesque.clients.admin.Admin: void close(java.time.Duration)>(v);
return;
}
public abstract void close(java.time.Duration);
public org.apache.kafkaesque.clients.admin.CreateTopicsResult createTopics(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.CreateTopicsResult v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.CreateTopicsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.CreateTopicsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.CreateTopicsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.CreateTopicsResult createTopics(java.util.Collection,org.apache.kafkaesque.clients.admin.CreateTopicsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.CreateTopicsResult createTopics(java.util.Collection, org.apache.kafkaesque.clients.admin.CreateTopicsOptions);
public org.apache.kafkaesque.clients.admin.DeleteTopicsResult deleteTopics(java.util.Collection)
{
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DeleteTopicsOptions v;
org.apache.kafkaesque.clients.admin.DeleteTopicsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DeleteTopicsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DeleteTopicsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DeleteTopicsResult deleteTopics(java.util.Collection,org.apache.kafkaesque.clients.admin.DeleteTopicsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DeleteTopicsResult deleteTopics(java.util.Collection, org.apache.kafkaesque.clients.admin.DeleteTopicsOptions);
public org.apache.kafkaesque.clients.admin.ListTopicsResult listTopics()
{
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.ListTopicsResult v;
org.apache.kafkaesque.clients.admin.ListTopicsOptions v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.ListTopicsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListTopicsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListTopicsResult listTopics(org.apache.kafkaesque.clients.admin.ListTopicsOptions)>(v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ListTopicsResult listTopics(org.apache.kafkaesque.clients.admin.ListTopicsOptions);
public org.apache.kafkaesque.clients.admin.DescribeTopicsResult describeTopics(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.DescribeTopicsOptions v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DescribeTopicsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DescribeTopicsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeTopicsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeTopicsResult describeTopics(java.util.Collection,org.apache.kafkaesque.clients.admin.DescribeTopicsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeTopicsResult describeTopics(java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeTopicsOptions);
public org.apache.kafkaesque.clients.admin.DescribeClusterResult describeCluster()
{
org.apache.kafkaesque.clients.admin.DescribeClusterOptions v;
org.apache.kafkaesque.clients.admin.DescribeClusterResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.DescribeClusterOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeClusterOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeClusterResult describeCluster(org.apache.kafkaesque.clients.admin.DescribeClusterOptions)>(v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeClusterResult describeCluster(org.apache.kafkaesque.clients.admin.DescribeClusterOptions);
public org.apache.kafkaesque.clients.admin.DescribeAclsResult describeAcls(org.apache.kafkaesque.common.acl.AclBindingFilter)
{
org.apache.kafkaesque.common.acl.AclBindingFilter v;
org.apache.kafkaesque.clients.admin.DescribeAclsOptions v;
org.apache.kafkaesque.clients.admin.DescribeAclsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: org.apache.kafkaesque.common.acl.AclBindingFilter;
v = new org.apache.kafkaesque.clients.admin.DescribeAclsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeAclsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeAclsResult describeAcls(org.apache.kafkaesque.common.acl.AclBindingFilter,org.apache.kafkaesque.clients.admin.DescribeAclsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeAclsResult describeAcls(org.apache.kafkaesque.common.acl.AclBindingFilter, org.apache.kafkaesque.clients.admin.DescribeAclsOptions);
public org.apache.kafkaesque.clients.admin.CreateAclsResult createAcls(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.CreateAclsOptions v;
org.apache.kafkaesque.clients.admin.CreateAclsResult v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.CreateAclsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.CreateAclsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.CreateAclsResult createAcls(java.util.Collection,org.apache.kafkaesque.clients.admin.CreateAclsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.CreateAclsResult createAcls(java.util.Collection, org.apache.kafkaesque.clients.admin.CreateAclsOptions);
public org.apache.kafkaesque.clients.admin.DeleteAclsResult deleteAcls(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.DeleteAclsResult v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DeleteAclsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DeleteAclsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DeleteAclsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DeleteAclsResult deleteAcls(java.util.Collection,org.apache.kafkaesque.clients.admin.DeleteAclsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DeleteAclsResult deleteAcls(java.util.Collection, org.apache.kafkaesque.clients.admin.DeleteAclsOptions);
public org.apache.kafkaesque.clients.admin.DescribeConfigsResult describeConfigs(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.DescribeConfigsResult v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DescribeConfigsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DescribeConfigsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeConfigsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeConfigsResult describeConfigs(java.util.Collection,org.apache.kafkaesque.clients.admin.DescribeConfigsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeConfigsResult describeConfigs(java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeConfigsOptions);
public org.apache.kafkaesque.clients.admin.AlterConfigsResult alterConfigs(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.AlterConfigsResult v;
org.apache.kafkaesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AlterConfigsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AlterConfigsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.AlterConfigsResult alterConfigs(java.util.Map,org.apache.kafkaesque.clients.admin.AlterConfigsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.AlterConfigsResult alterConfigs(java.util.Map, org.apache.kafkaesque.clients.admin.AlterConfigsOptions);
public org.apache.kafkaesque.clients.admin.AlterConfigsResult incrementalAlterConfigs(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.AlterConfigsResult v;
org.apache.kafkaesque.clients.admin.AlterConfigsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AlterConfigsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AlterConfigsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.AlterConfigsResult incrementalAlterConfigs(java.util.Map,org.apache.kafkaesque.clients.admin.AlterConfigsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.AlterConfigsResult incrementalAlterConfigs(java.util.Map, org.apache.kafkaesque.clients.admin.AlterConfigsOptions);
public org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsResult alterReplicaLogDirs(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsOptions v;
org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsResult alterReplicaLogDirs(java.util.Map,org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsResult alterReplicaLogDirs(java.util.Map, org.apache.kafkaesque.clients.admin.AlterReplicaLogDirsOptions);
public org.apache.kafkaesque.clients.admin.DescribeLogDirsResult describeLogDirs(java.util.Collection)
{
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DescribeLogDirsResult v;
org.apache.kafkaesque.clients.admin.DescribeLogDirsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DescribeLogDirsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeLogDirsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeLogDirsResult describeLogDirs(java.util.Collection,org.apache.kafkaesque.clients.admin.DescribeLogDirsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeLogDirsResult describeLogDirs(java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeLogDirsOptions);
public org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsResult describeReplicaLogDirs(java.util.Collection)
{
java.util.Collection v;
org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsOptions v;
org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsResult describeReplicaLogDirs(java.util.Collection,org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsResult describeReplicaLogDirs(java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeReplicaLogDirsOptions);
public org.apache.kafkaesque.clients.admin.CreatePartitionsResult createPartitions(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.CreatePartitionsResult v;
org.apache.kafkaesque.clients.admin.CreatePartitionsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.CreatePartitionsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.CreatePartitionsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.CreatePartitionsResult createPartitions(java.util.Map,org.apache.kafkaesque.clients.admin.CreatePartitionsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.CreatePartitionsResult createPartitions(java.util.Map, org.apache.kafkaesque.clients.admin.CreatePartitionsOptions);
public org.apache.kafkaesque.clients.admin.DeleteRecordsResult deleteRecords(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.DeleteRecordsResult v;
org.apache.kafkaesque.clients.admin.DeleteRecordsOptions v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.DeleteRecordsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DeleteRecordsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DeleteRecordsResult deleteRecords(java.util.Map,org.apache.kafkaesque.clients.admin.DeleteRecordsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DeleteRecordsResult deleteRecords(java.util.Map, org.apache.kafkaesque.clients.admin.DeleteRecordsOptions);
public org.apache.kafkaesque.clients.admin.CreateDelegationTokenResult createDelegationToken()
{
org.apache.kafkaesque.clients.admin.CreateDelegationTokenOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.CreateDelegationTokenResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.CreateDelegationTokenOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.CreateDelegationTokenOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.CreateDelegationTokenResult createDelegationToken(org.apache.kafkaesque.clients.admin.CreateDelegationTokenOptions)>(v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.CreateDelegationTokenResult createDelegationToken(org.apache.kafkaesque.clients.admin.CreateDelegationTokenOptions);
public org.apache.kafkaesque.clients.admin.RenewDelegationTokenResult renewDelegationToken(byte[])
{
byte[] v;
org.apache.kafkaesque.clients.admin.RenewDelegationTokenResult v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.RenewDelegationTokenOptions v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: byte[];
v = new org.apache.kafkaesque.clients.admin.RenewDelegationTokenOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.RenewDelegationTokenOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.RenewDelegationTokenResult renewDelegationToken(byte[],org.apache.kafkaesque.clients.admin.RenewDelegationTokenOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.RenewDelegationTokenResult renewDelegationToken(byte[], org.apache.kafkaesque.clients.admin.RenewDelegationTokenOptions);
public org.apache.kafkaesque.clients.admin.ExpireDelegationTokenResult expireDelegationToken(byte[])
{
byte[] v;
org.apache.kafkaesque.clients.admin.ExpireDelegationTokenResult v;
org.apache.kafkaesque.clients.admin.ExpireDelegationTokenOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: byte[];
v = new org.apache.kafkaesque.clients.admin.ExpireDelegationTokenOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ExpireDelegationTokenOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ExpireDelegationTokenResult expireDelegationToken(byte[],org.apache.kafkaesque.clients.admin.ExpireDelegationTokenOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ExpireDelegationTokenResult expireDelegationToken(byte[], org.apache.kafkaesque.clients.admin.ExpireDelegationTokenOptions);
public org.apache.kafkaesque.clients.admin.DescribeDelegationTokenResult describeDelegationToken()
{
org.apache.kafkaesque.clients.admin.DescribeDelegationTokenOptions v;
org.apache.kafkaesque.clients.admin.DescribeDelegationTokenResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.DescribeDelegationTokenOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeDelegationTokenOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeDelegationTokenResult describeDelegationToken(org.apache.kafkaesque.clients.admin.DescribeDelegationTokenOptions)>(v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DescribeDelegationTokenResult describeDelegationToken(org.apache.kafkaesque.clients.admin.DescribeDelegationTokenOptions);
public abstract org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsResult describeConsumerGroups(java.util.Collection, org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsOptions);
public org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsResult describeConsumerGroups(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsOptions v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsResult describeConsumerGroups(java.util.Collection,org.apache.kafkaesque.clients.admin.DescribeConsumerGroupsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ListConsumerGroupsResult listConsumerGroups(org.apache.kafkaesque.clients.admin.ListConsumerGroupsOptions);
public org.apache.kafkaesque.clients.admin.ListConsumerGroupsResult listConsumerGroups()
{
org.apache.kafkaesque.clients.admin.ListConsumerGroupsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.ListConsumerGroupsOptions v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.ListConsumerGroupsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListConsumerGroupsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListConsumerGroupsResult listConsumerGroups(org.apache.kafkaesque.clients.admin.ListConsumerGroupsOptions)>(v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsResult listConsumerGroupOffsets(java.lang.String, org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsOptions);
public org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsResult listConsumerGroupOffsets(java.lang.String)
{
org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsResult v;
org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsOptions v;
java.lang.String v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.lang.String;
v = new org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsResult listConsumerGroupOffsets(java.lang.String,org.apache.kafkaesque.clients.admin.ListConsumerGroupOffsetsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsResult deleteConsumerGroups(java.util.Collection, org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsOptions);
public org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsResult deleteConsumerGroups(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsResult v;
org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsOptions v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsResult deleteConsumerGroups(java.util.Collection,org.apache.kafkaesque.clients.admin.DeleteConsumerGroupsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsResult deleteConsumerGroupOffsets(java.lang.String, java.util.Set, org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsOptions);
public org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsResult deleteConsumerGroupOffsets(java.lang.String, java.util.Set)
{
java.util.Set v;
java.lang.String v;
org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.lang.String;
v := @parameter: java.util.Set;
v = new org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsResult deleteConsumerGroupOffsets(java.lang.String,java.util.Set,org.apache.kafkaesque.clients.admin.DeleteConsumerGroupOffsetsOptions)>(v, v, v);
return v;
}
public org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult electPreferredLeaders(java.util.Collection)
{
org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult v;
java.util.Collection v;
org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v = new org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult electPreferredLeaders(java.util.Collection,org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions)>(v, v);
return v;
}
public org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult electPreferredLeaders(java.util.Collection, org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions)
{
org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult v;
java.util.Collection v;
org.apache.kafkaesque.common.ElectionType v;
java.lang.Integer v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.ElectLeadersResult v;
java.util.HashSet v;
org.apache.kafkaesque.clients.admin.ElectLeadersOptions v;
org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Collection;
v := @parameter: org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions;
v = new org.apache.kafkaesque.clients.admin.ElectLeadersOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ElectLeadersOptions: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesque.clients.admin.ElectPreferredLeadersOptions: java.lang.Integer timeoutMs()>();
virtualinvoke v.<org.apache.kafkaesque.clients.admin.ElectLeadersOptions: org.apache.kafkaesque.clients.admin.AbstractOptions timeoutMs(java.lang.Integer)>(v);
if v != null goto label;
v = null;
goto label;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
label:
v = new org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult;
v = <org.apache.kafkaesque.common.ElectionType: org.apache.kafkaesque.common.ElectionType PREFERRED>;
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ElectLeadersResult electLeaders(org.apache.kafkaesque.common.ElectionType,java.util.Set,org.apache.kafkaesque.clients.admin.ElectLeadersOptions)>(v, v, v);
specialinvoke v.<org.apache.kafkaesque.clients.admin.ElectPreferredLeadersResult: void <init>(org.apache.kafkaesque.clients.admin.ElectLeadersResult)>(v);
return v;
}
public org.apache.kafkaesque.clients.admin.ElectLeadersResult electLeaders(org.apache.kafkaesque.common.ElectionType, java.util.Set)
{
java.util.Set v;
org.apache.kafkaesque.clients.admin.ElectLeadersOptions v;
org.apache.kafkaesque.common.ElectionType v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.ElectLeadersResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: org.apache.kafkaesque.common.ElectionType;
v := @parameter: java.util.Set;
v = new org.apache.kafkaesque.clients.admin.ElectLeadersOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ElectLeadersOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ElectLeadersResult electLeaders(org.apache.kafkaesque.common.ElectionType,java.util.Set,org.apache.kafkaesque.clients.admin.ElectLeadersOptions)>(v, v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ElectLeadersResult electLeaders(org.apache.kafkaesque.common.ElectionType, java.util.Set, org.apache.kafkaesque.clients.admin.ElectLeadersOptions);
public org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsResult alterPartitionReassignments(java.util.Map)
{
java.util.Map v;
org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsResult alterPartitionReassignments(java.util.Map,org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsResult alterPartitionReassignments(java.util.Map, org.apache.kafkaesque.clients.admin.AlterPartitionReassignmentsOptions);
public org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments()
{
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v = new org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)>(v);
return v;
}
public org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Set)
{
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions v;
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult v;
java.util.Set v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Set;
v = new org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Set,org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)>(v, v);
return v;
}
public org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Set, org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)
{
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions v;
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult v;
java.util.Optional v;
java.util.Set v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Set;
v := @parameter: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions;
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Optional,org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)>(v, v);
return v;
}
public org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)
{
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions v;
org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult v;
java.util.Optional v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Optional,org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsResult listPartitionReassignments(java.util.Optional, org.apache.kafkaesque.clients.admin.ListPartitionReassignmentsOptions);
public abstract org.apache.kafkaesque.clients.admin.RemoveMembersFromConsumerGroupResult removeMembersFromConsumerGroup(java.lang.String, org.apache.kafkaesque.clients.admin.RemoveMembersFromConsumerGroupOptions);
public org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsResult alterConsumerGroupOffsets(java.lang.String, java.util.Map)
{
org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsOptions v;
java.util.Map v;
java.lang.String v;
org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsResult v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsResult alterConsumerGroupOffsets(java.lang.String,java.util.Map,org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsOptions)>(v, v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsResult alterConsumerGroupOffsets(java.lang.String, java.util.Map, org.apache.kafkaesque.clients.admin.AlterConsumerGroupOffsetsOptions);
public org.apache.kafkaesque.clients.admin.ListOffsetsResult listOffsets(java.util.Map)
{
org.apache.kafkaesque.clients.admin.ListOffsetsResult v;
java.util.Map v;
org.apache.kafkaesque.clients.admin.ListOffsetsOptions v;
org.apache.kafkaesque.clients.admin.Admin v;
v := @this: org.apache.kafkaesque.clients.admin.Admin;
v := @parameter: java.util.Map;
v = new org.apache.kafkaesque.clients.admin.ListOffsetsOptions;
specialinvoke v.<org.apache.kafkaesque.clients.admin.ListOffsetsOptions: void <init>()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.admin.Admin: org.apache.kafkaesque.clients.admin.ListOffsetsResult listOffsets(java.util.Map,org.apache.kafkaesque.clients.admin.ListOffsetsOptions)>(v, v);
return v;
}
public abstract org.apache.kafkaesque.clients.admin.ListOffsetsResult listOffsets(java.util.Map, org.apache.kafkaesque.clients.admin.ListOffsetsOptions);
public abstract java.util.Map metrics();
}