Interface ManagedKafkaGrpc.AsyncService (0.20.0)

public static interface ManagedKafkaGrpc.AsyncService

The service that a client application uses to manage Apache Kafka clusters, topics and consumer groups.

Methods

addAclEntry(AddAclEntryRequest request, StreamObserver<AddAclEntryResponse> responseObserver)

public default void addAclEntry(AddAclEntryRequest request, StreamObserver<AddAclEntryResponse> responseObserver)

Incremental update: Adds an acl entry to an acl. Creates the acl if it does not exist yet.

Parameters
Name	Description
`request`	`AddAclEntryRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<AddAclEntryResponse>`

createAcl(CreateAclRequest request, StreamObserver<Acl> responseObserver)

public default void createAcl(CreateAclRequest request, StreamObserver<Acl> responseObserver)

Creates a new acl in the given project, location, and cluster.

Parameters
Name	Description
`request`	`CreateAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

createCluster(CreateClusterRequest request, StreamObserver<Operation> responseObserver)

public default void createCluster(CreateClusterRequest request, StreamObserver<Operation> responseObserver)

Creates a new cluster in a given project and location.

Parameters
Name	Description
`request`	`CreateClusterRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

createTopic(CreateTopicRequest request, StreamObserver<Topic> responseObserver)

public default void createTopic(CreateTopicRequest request, StreamObserver<Topic> responseObserver)

Creates a new topic in a given project and location.

Parameters
Name	Description
`request`	`CreateTopicRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Topic>`

deleteAcl(DeleteAclRequest request, StreamObserver<Empty> responseObserver)

public default void deleteAcl(DeleteAclRequest request, StreamObserver<Empty> responseObserver)

Deletes an acl.

Parameters
Name	Description
`request`	`DeleteAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

deleteCluster(DeleteClusterRequest request, StreamObserver<Operation> responseObserver)

public default void deleteCluster(DeleteClusterRequest request, StreamObserver<Operation> responseObserver)

Deletes a single cluster.

Parameters
Name	Description
`request`	`DeleteClusterRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

deleteConsumerGroup(DeleteConsumerGroupRequest request, StreamObserver<Empty> responseObserver)

public default void deleteConsumerGroup(DeleteConsumerGroupRequest request, StreamObserver<Empty> responseObserver)

Deletes a single consumer group.

Parameters
Name	Description
`request`	`DeleteConsumerGroupRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

deleteTopic(DeleteTopicRequest request, StreamObserver<Empty> responseObserver)

public default void deleteTopic(DeleteTopicRequest request, StreamObserver<Empty> responseObserver)

Deletes a single topic.

Parameters
Name	Description
`request`	`DeleteTopicRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Empty>`

getAcl(GetAclRequest request, StreamObserver<Acl> responseObserver)

public default void getAcl(GetAclRequest request, StreamObserver<Acl> responseObserver)

Returns the properties of a single acl.

Parameters
Name	Description
`request`	`GetAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

getCluster(GetClusterRequest request, StreamObserver<Cluster> responseObserver)

public default void getCluster(GetClusterRequest request, StreamObserver<Cluster> responseObserver)

Returns the properties of a single cluster.

Parameters
Name	Description
`request`	`GetClusterRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Cluster>`

getConsumerGroup(GetConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)

public default void getConsumerGroup(GetConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)

Returns the properties of a single consumer group.

Parameters
Name	Description
`request`	`GetConsumerGroupRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ConsumerGroup>`

getTopic(GetTopicRequest request, StreamObserver<Topic> responseObserver)

public default void getTopic(GetTopicRequest request, StreamObserver<Topic> responseObserver)

Returns the properties of a single topic.

Parameters
Name	Description
`request`	`GetTopicRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Topic>`

listAcls(ListAclsRequest request, StreamObserver<ListAclsResponse> responseObserver)

public default void listAcls(ListAclsRequest request, StreamObserver<ListAclsResponse> responseObserver)

Lists the acls in a given cluster.

Parameters
Name	Description
`request`	`ListAclsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListAclsResponse>`

listClusters(ListClustersRequest request, StreamObserver<ListClustersResponse> responseObserver)

public default void listClusters(ListClustersRequest request, StreamObserver<ListClustersResponse> responseObserver)

Lists the clusters in a given project and location.

Parameters
Name	Description
`request`	`ListClustersRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListClustersResponse>`

listConsumerGroups(ListConsumerGroupsRequest request, StreamObserver<ListConsumerGroupsResponse> responseObserver)

public default void listConsumerGroups(ListConsumerGroupsRequest request, StreamObserver<ListConsumerGroupsResponse> responseObserver)

Lists the consumer groups in a given cluster.

Parameters
Name	Description
`request`	`ListConsumerGroupsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListConsumerGroupsResponse>`

listTopics(ListTopicsRequest request, StreamObserver<ListTopicsResponse> responseObserver)

public default void listTopics(ListTopicsRequest request, StreamObserver<ListTopicsResponse> responseObserver)

Lists the topics in a given cluster.

Parameters
Name	Description
`request`	`ListTopicsRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ListTopicsResponse>`

removeAclEntry(RemoveAclEntryRequest request, StreamObserver<RemoveAclEntryResponse> responseObserver)

public default void removeAclEntry(RemoveAclEntryRequest request, StreamObserver<RemoveAclEntryResponse> responseObserver)

Incremental update: Removes an acl entry from an acl. Deletes the acl if its acl entries become empty (i.e. if the removed entry was the last one in the acl).

Parameters
Name	Description
`request`	`RemoveAclEntryRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<RemoveAclEntryResponse>`

updateAcl(UpdateAclRequest request, StreamObserver<Acl> responseObserver)

public default void updateAcl(UpdateAclRequest request, StreamObserver<Acl> responseObserver)

Updates the properties of a single acl.

Parameters
Name	Description
`request`	`UpdateAclRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Acl>`

updateCluster(UpdateClusterRequest request, StreamObserver<Operation> responseObserver)

public default void updateCluster(UpdateClusterRequest request, StreamObserver<Operation> responseObserver)

Updates the properties of a single cluster.

Parameters
Name	Description
`request`	`UpdateClusterRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Operation>`

updateConsumerGroup(UpdateConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)

public default void updateConsumerGroup(UpdateConsumerGroupRequest request, StreamObserver<ConsumerGroup> responseObserver)

Updates the properties of a single consumer group.

Parameters
Name	Description
`request`	`UpdateConsumerGroupRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<ConsumerGroup>`

updateTopic(UpdateTopicRequest request, StreamObserver<Topic> responseObserver)

public default void updateTopic(UpdateTopicRequest request, StreamObserver<Topic> responseObserver)

Updates the properties of a single topic.

Parameters
Name	Description
`request`	`UpdateTopicRequest`
`responseObserver`	`io.grpc.stub.StreamObserver<Topic>`

Interface ManagedKafkaGrpc.AsyncService (0.20.0) Stay organized with collections Save and categorize content based on your preferences.