Class MockController

java.lang.Object
org.apache.kafka.common.test.MockController
All Implemented Interfaces:
AutoCloseable, org.apache.kafka.controller.Controller, org.apache.kafka.metadata.authorizer.AclMutator, org.apache.kafka.metadata.authorizer.ConfluentKeyValueStreamMutator
public class MockController extends Object implements org.apache.kafka.controller.Controller

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    MockController.Builder
     

  • Method Summary

    Modifier and Type
    Method
    Description
    CompletableFuture<Void>
    addConfluentKeyValueStreamChangeRecord(OptionalLong deadlineNs, org.apache.kafka.metadata.InternalTopicType recordType, byte[] key, byte[] value, short partitionId, long offset)
     
    CompletableFuture<org.apache.kafka.common.message.AllocateProducerIdsResponseData>
    allocateProducerIds(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AllocateProducerIdsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterBrokerHealthResponseData>
    alterBrokerHealth(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterBrokerHealthRequestData request)
     
    CompletableFuture<org.apache.kafka.server.common.AlterReplicaExclusionsReply>
    alterBrokerReplicaExclusions(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterBrokerReplicaExclusionsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterCellResponseData>
    alterCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AlterCellRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterCellMigrationResponseData>
    alterCellMigration(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AlterCellMigrationRequest request)
     
    CompletableFuture<Map<org.apache.kafka.common.quota.ClientQuotaEntity, org.apache.kafka.common.requests.ApiError>>
    alterClientQuotas(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.quota.ClientQuotaAlteration> quotaAlterations, boolean validateOnly)
     
    CompletableFuture<org.apache.kafka.common.message.AlterClusterLinksResponseData>
    alterClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterClusterLinksRequestData request)
     
    CompletableFuture<List<org.apache.kafka.common.message.AlterMirrorsResponseData.AlterMirrorResult>>
    alterMirrors(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.message.AlterMirrorsRequestData.MirrorOperation> ops, boolean validateOnly)
     
    CompletableFuture<org.apache.kafka.common.message.AlterMirrorTopicsResponseData>
    alterMirrorTopic(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterMirrorTopicsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterPartitionResponseData>
    alterPartition(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterPartitionRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData>
    alterPartitionReassignments(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AlterUserScramCredentialsResponseData>
    alterUserScramCredentials(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterUserScramCredentialsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AssignBrokersToCellResponseData>
    assignBrokersToCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AssignBrokersToCellRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.AssignReplicasToDirsResponseData>
    assignReplicasToDirs(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AssignReplicasToDirsRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.AssignTenantsToCellResponseData>
    assignTenantsToCells(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AssignTenantsToCellRequest request)
     
    void
    beginShutdown()
     
    void
    close()
     
    CompletableFuture<org.apache.kafka.common.message.ControllerListClusterLinksResponseData>
    controllerListClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ControllerListClusterLinksRequestData request)
     
    CompletableFuture<List<org.apache.kafka.server.authorizer.AclCreateResult>>
    createAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBinding> aclBindings)
     
    CompletableFuture<List<org.apache.kafka.server.authorizer.AclCreateResult>>
    createAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBinding> aclBindings, org.apache.kafka.common.acl.AclState aclState)
     
    CompletableFuture<org.apache.kafka.common.message.CreateCellResponseData>
    createCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.CreateCellRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.CreateClusterLinksResponseData>
    createClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateClusterLinksRequestData request, org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal)
     
    CompletableFuture<org.apache.kafka.common.message.CreateDelegationTokenResponseData>
    createDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateDelegationTokenRequestData request)
     
    CompletableFuture<List<org.apache.kafka.common.message.CreatePartitionsResponseData.CreatePartitionsTopicResult>>
    createPartitions(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.message.CreatePartitionsRequestData.CreatePartitionsTopic> topicList, boolean validateOnly)
     
    CompletableFuture<org.apache.kafka.common.message.CreateTopicsResponseData>
    createTopics(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateTopicsRequestData request, Set<String> describable)
     
    int
    curClaimEpoch()
     
    CompletableFuture<List<org.apache.kafka.server.authorizer.AclDeleteResult>>
    deleteAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBindingFilter> aclBindingFilters)
     
    CompletableFuture<List<org.apache.kafka.server.authorizer.AclDeleteResult>>
    deleteAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBindingFilter> aclBindingFilters, org.apache.kafka.common.acl.AclState aclState)
     
    CompletableFuture<org.apache.kafka.common.message.DeleteCellResponseData>
    deleteCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DeleteCellRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.DeleteClusterLinksResponseData>
    deleteClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.DeleteClusterLinksRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.DeleteTenantsResponseData>
    deleteTenants(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DeleteTenantsRequest request)
     
    CompletableFuture<Map<org.apache.kafka.common.Uuid, org.apache.kafka.common.requests.ApiError>>
    deleteTopics(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.Uuid> topicIds)
     
    CompletableFuture<org.apache.kafka.common.message.DescribeBrokerHealthResponseData>
    describeBrokerHealth(org.apache.kafka.controller.ControllerRequestContext context)
     
    CompletableFuture<Map<Integer,String>>
    describeBrokerReplicaExclusions(org.apache.kafka.controller.ControllerRequestContext context)
     
    CompletableFuture<org.apache.kafka.common.message.DescribeCellMigrationResponseData>
    describeCellMigration(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeCellMigrationRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.DescribeCellsResponseData>
    describeCells(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeCellsRequest request)
     
    CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.controller.ResultOrError<Map<String,String>>>>
    describeConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Collection<String>> resources)
     
    CompletableFuture<org.apache.kafka.common.message.DescribeTenantsResponseData>
    describeTenants(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeTenantsRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.ElectLeadersResponseData>
    electLeaders(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ElectLeadersRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.ExpireDelegationTokenResponseData>
    expireDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ExpireDelegationTokenRequestData request)
     
    CompletableFuture<org.apache.kafka.metadata.FinalizedControllerFeatures>
    finalizedFeatures(org.apache.kafka.controller.ControllerRequestContext context)
     
    CompletableFuture<Map<String, org.apache.kafka.common.Uuid>>
    findAllTopicIds(org.apache.kafka.controller.ControllerRequestContext context)
     
    CompletableFuture<Map<String, org.apache.kafka.controller.ResultOrError<org.apache.kafka.common.Uuid>>>
    findTopicIds(org.apache.kafka.controller.ControllerRequestContext context, Collection<String> topicNames)
     
    CompletableFuture<Map<org.apache.kafka.common.Uuid, org.apache.kafka.controller.ResultOrError<String>>>
    findTopicNames(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.Uuid> topicIds)
     
    List<List<Object>>
    getAddConfluentKeyValueStreamChangeRecordCalls()
     
    CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.common.requests.ApiError>>
    incrementalAlterConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Map<String, Map.Entry<org.apache.kafka.clients.admin.AlterConfigOp.OpType, String>>> configChanges, boolean validateOnly)
     
    CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.common.requests.ApiError>>
    legacyAlterConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Map<String,String>> newConfigs, boolean validateOnly)
     
    CompletableFuture<org.apache.kafka.common.message.ListPartitionReassignmentsResponseData>
    listPartitionReassignments(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ListPartitionReassignmentsRequestData request)
     
    CompletableFuture<org.apache.kafka.metadata.BrokerHeartbeatReply>
    processBrokerHeartbeat(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.BrokerHeartbeatRequestData request)
     
    CompletableFuture<Map<Short, Map<Short,Long>>>
    readKeyValueStreamsTopicOffsets()
     
    CompletableFuture<org.apache.kafka.metadata.BrokerRegistrationReply>
    registerBroker(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.BrokerRegistrationRequestData request)
     
    CompletableFuture<Void>
    registerController(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ControllerRegistrationRequestData request)
     
    CompletableFuture<org.apache.kafka.common.message.RenewDelegationTokenResponseData>
    renewDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.RenewDelegationTokenRequestData request)
     
    void
    setActive(boolean active)
     
    CompletableFuture<org.apache.kafka.common.message.UnAssignBrokersFromCellResponseData>
    unassignBrokersFromCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.UnAssignBrokersFromCellRequest request)
     
    CompletableFuture<org.apache.kafka.common.message.MetadataResponseData.MetadataResponseBrokerCollection>
    unfencedBrokerEndpoints(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.network.ListenerName listenerName)
     
    CompletableFuture<Void>
    unregisterBroker(org.apache.kafka.controller.ControllerRequestContext context, int brokerId)
     
    CompletableFuture<org.apache.kafka.common.message.UpdateFeaturesResponseData>
    updateFeatures(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.UpdateFeaturesRequestData request)
     
    CompletableFuture<Void>
    waitForReadyBrokers(int minBrokers)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.kafka.controller.Controller

    isActive

  • Method Details

    • createAcls

      public CompletableFuture<List<org.apache.kafka.server.authorizer.AclCreateResult>> createAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBinding> aclBindings)
      Specified by:
      createAcls in interface org.apache.kafka.metadata.authorizer.AclMutator

    • createAcls

      public CompletableFuture<List<org.apache.kafka.server.authorizer.AclCreateResult>> createAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBinding> aclBindings, org.apache.kafka.common.acl.AclState aclState)
      Specified by:
      createAcls in interface org.apache.kafka.metadata.authorizer.AclMutator

    • deleteAcls

      public CompletableFuture<List<org.apache.kafka.server.authorizer.AclDeleteResult>> deleteAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBindingFilter> aclBindingFilters)
      Specified by:
      deleteAcls in interface org.apache.kafka.metadata.authorizer.AclMutator

    • deleteAcls

      public CompletableFuture<List<org.apache.kafka.server.authorizer.AclDeleteResult>> deleteAcls(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.acl.AclBindingFilter> aclBindingFilters, org.apache.kafka.common.acl.AclState aclState)
      Specified by:
      deleteAcls in interface org.apache.kafka.metadata.authorizer.AclMutator

    • addConfluentKeyValueStreamChangeRecord

      public CompletableFuture<Void> addConfluentKeyValueStreamChangeRecord(OptionalLong deadlineNs, org.apache.kafka.metadata.InternalTopicType recordType, byte[] key, byte[] value, short partitionId, long offset)
      Specified by:
      addConfluentKeyValueStreamChangeRecord in interface org.apache.kafka.metadata.authorizer.ConfluentKeyValueStreamMutator

    • getAddConfluentKeyValueStreamChangeRecordCalls

      public List<List<Object>> getAddConfluentKeyValueStreamChangeRecordCalls()

    • unfencedBrokerEndpoints

      public CompletableFuture<org.apache.kafka.common.message.MetadataResponseData.MetadataResponseBrokerCollection> unfencedBrokerEndpoints(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.network.ListenerName listenerName)
      Specified by:
      unfencedBrokerEndpoints in interface org.apache.kafka.controller.Controller

    • alterPartition

      public CompletableFuture<org.apache.kafka.common.message.AlterPartitionResponseData> alterPartition(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterPartitionRequestData request)
      Specified by:
      alterPartition in interface org.apache.kafka.controller.Controller

    • alterUserScramCredentials

      public CompletableFuture<org.apache.kafka.common.message.AlterUserScramCredentialsResponseData> alterUserScramCredentials(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterUserScramCredentialsRequestData request)
      Specified by:
      alterUserScramCredentials in interface org.apache.kafka.controller.Controller

    • createDelegationToken

      public CompletableFuture<org.apache.kafka.common.message.CreateDelegationTokenResponseData> createDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateDelegationTokenRequestData request)
      Specified by:
      createDelegationToken in interface org.apache.kafka.controller.Controller

    • renewDelegationToken

      public CompletableFuture<org.apache.kafka.common.message.RenewDelegationTokenResponseData> renewDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.RenewDelegationTokenRequestData request)
      Specified by:
      renewDelegationToken in interface org.apache.kafka.controller.Controller

    • expireDelegationToken

      public CompletableFuture<org.apache.kafka.common.message.ExpireDelegationTokenResponseData> expireDelegationToken(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ExpireDelegationTokenRequestData request)
      Specified by:
      expireDelegationToken in interface org.apache.kafka.controller.Controller

    • createTopics

      public CompletableFuture<org.apache.kafka.common.message.CreateTopicsResponseData> createTopics(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateTopicsRequestData request, Set<String> describable)
      Specified by:
      createTopics in interface org.apache.kafka.controller.Controller

    • unregisterBroker

      public CompletableFuture<Void> unregisterBroker(org.apache.kafka.controller.ControllerRequestContext context, int brokerId)
      Specified by:
      unregisterBroker in interface org.apache.kafka.controller.Controller

    • findTopicIds

      public CompletableFuture<Map<String, org.apache.kafka.controller.ResultOrError<org.apache.kafka.common.Uuid>>> findTopicIds(org.apache.kafka.controller.ControllerRequestContext context, Collection<String> topicNames)
      Specified by:
      findTopicIds in interface org.apache.kafka.controller.Controller

    • readKeyValueStreamsTopicOffsets

      public CompletableFuture<Map<Short, Map<Short,Long>>> readKeyValueStreamsTopicOffsets()
      Specified by:
      readKeyValueStreamsTopicOffsets in interface org.apache.kafka.controller.Controller

    • findAllTopicIds

      public CompletableFuture<Map<String, org.apache.kafka.common.Uuid>> findAllTopicIds(org.apache.kafka.controller.ControllerRequestContext context)
      Specified by:
      findAllTopicIds in interface org.apache.kafka.controller.Controller

    • findTopicNames

      public CompletableFuture<Map<org.apache.kafka.common.Uuid, org.apache.kafka.controller.ResultOrError<String>>> findTopicNames(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.Uuid> topicIds)
      Specified by:
      findTopicNames in interface org.apache.kafka.controller.Controller

    • deleteTopics

      public CompletableFuture<Map<org.apache.kafka.common.Uuid, org.apache.kafka.common.requests.ApiError>> deleteTopics(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.Uuid> topicIds)
      Specified by:
      deleteTopics in interface org.apache.kafka.controller.Controller

    • describeConfigs

      public CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.controller.ResultOrError<Map<String,String>>>> describeConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Collection<String>> resources)
      Specified by:
      describeConfigs in interface org.apache.kafka.controller.Controller

    • electLeaders

      public CompletableFuture<org.apache.kafka.common.message.ElectLeadersResponseData> electLeaders(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ElectLeadersRequestData request)
      Specified by:
      electLeaders in interface org.apache.kafka.controller.Controller

    • finalizedFeatures

      public CompletableFuture<org.apache.kafka.metadata.FinalizedControllerFeatures> finalizedFeatures(org.apache.kafka.controller.ControllerRequestContext context)
      Specified by:
      finalizedFeatures in interface org.apache.kafka.controller.Controller

    • createClusterLinks

      public CompletableFuture<org.apache.kafka.common.message.CreateClusterLinksResponseData> createClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.CreateClusterLinksRequestData request, org.apache.kafka.common.security.auth.KafkaPrincipal kafkaPrincipal)
      Specified by:
      createClusterLinks in interface org.apache.kafka.controller.Controller

    • deleteClusterLinks

      public CompletableFuture<org.apache.kafka.common.message.DeleteClusterLinksResponseData> deleteClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.DeleteClusterLinksRequestData request)
      Specified by:
      deleteClusterLinks in interface org.apache.kafka.controller.Controller

    • alterMirrorTopic

      public CompletableFuture<org.apache.kafka.common.message.AlterMirrorTopicsResponseData> alterMirrorTopic(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterMirrorTopicsRequestData request)
      Specified by:
      alterMirrorTopic in interface org.apache.kafka.controller.Controller

    • alterClusterLinks

      public CompletableFuture<org.apache.kafka.common.message.AlterClusterLinksResponseData> alterClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterClusterLinksRequestData request)
      Specified by:
      alterClusterLinks in interface org.apache.kafka.controller.Controller

    • controllerListClusterLinks

      public CompletableFuture<org.apache.kafka.common.message.ControllerListClusterLinksResponseData> controllerListClusterLinks(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ControllerListClusterLinksRequestData request)
      Specified by:
      controllerListClusterLinks in interface org.apache.kafka.controller.Controller

    • alterMirrors

      public CompletableFuture<List<org.apache.kafka.common.message.AlterMirrorsResponseData.AlterMirrorResult>> alterMirrors(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.message.AlterMirrorsRequestData.MirrorOperation> ops, boolean validateOnly)
      Specified by:
      alterMirrors in interface org.apache.kafka.controller.Controller

    • describeCells

      public CompletableFuture<org.apache.kafka.common.message.DescribeCellsResponseData> describeCells(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeCellsRequest request)
      Specified by:
      describeCells in interface org.apache.kafka.controller.Controller

    • createCell

      public CompletableFuture<org.apache.kafka.common.message.CreateCellResponseData> createCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.CreateCellRequest request)
      Specified by:
      createCell in interface org.apache.kafka.controller.Controller

    • deleteCell

      public CompletableFuture<org.apache.kafka.common.message.DeleteCellResponseData> deleteCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DeleteCellRequest request)
      Specified by:
      deleteCell in interface org.apache.kafka.controller.Controller

    • alterCell

      public CompletableFuture<org.apache.kafka.common.message.AlterCellResponseData> alterCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AlterCellRequest request)
      Specified by:
      alterCell in interface org.apache.kafka.controller.Controller

    • assignBrokersToCell

      public CompletableFuture<org.apache.kafka.common.message.AssignBrokersToCellResponseData> assignBrokersToCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AssignBrokersToCellRequest request)
      Specified by:
      assignBrokersToCell in interface org.apache.kafka.controller.Controller

    • unassignBrokersFromCell

      public CompletableFuture<org.apache.kafka.common.message.UnAssignBrokersFromCellResponseData> unassignBrokersFromCell(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.UnAssignBrokersFromCellRequest request)
      Specified by:
      unassignBrokersFromCell in interface org.apache.kafka.controller.Controller

    • assignTenantsToCells

      public CompletableFuture<org.apache.kafka.common.message.AssignTenantsToCellResponseData> assignTenantsToCells(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AssignTenantsToCellRequest request)
      Specified by:
      assignTenantsToCells in interface org.apache.kafka.controller.Controller

    • describeTenants

      public CompletableFuture<org.apache.kafka.common.message.DescribeTenantsResponseData> describeTenants(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeTenantsRequest request)
      Specified by:
      describeTenants in interface org.apache.kafka.controller.Controller

    • deleteTenants

      public CompletableFuture<org.apache.kafka.common.message.DeleteTenantsResponseData> deleteTenants(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DeleteTenantsRequest request)
      Specified by:
      deleteTenants in interface org.apache.kafka.controller.Controller

    • alterCellMigration

      public CompletableFuture<org.apache.kafka.common.message.AlterCellMigrationResponseData> alterCellMigration(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.AlterCellMigrationRequest request)
      Specified by:
      alterCellMigration in interface org.apache.kafka.controller.Controller

    • describeCellMigration

      public CompletableFuture<org.apache.kafka.common.message.DescribeCellMigrationResponseData> describeCellMigration(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.requests.DescribeCellMigrationRequest request)
      Specified by:
      describeCellMigration in interface org.apache.kafka.controller.Controller

    • incrementalAlterConfigs

      public CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.common.requests.ApiError>> incrementalAlterConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Map<String, Map.Entry<org.apache.kafka.clients.admin.AlterConfigOp.OpType, String>>> configChanges, boolean validateOnly)
      Specified by:
      incrementalAlterConfigs in interface org.apache.kafka.controller.Controller

    • alterPartitionReassignments

      public CompletableFuture<org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData> alterPartitionReassignments(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData request)
      Specified by:
      alterPartitionReassignments in interface org.apache.kafka.controller.Controller

    • listPartitionReassignments

      public CompletableFuture<org.apache.kafka.common.message.ListPartitionReassignmentsResponseData> listPartitionReassignments(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ListPartitionReassignmentsRequestData request)
      Specified by:
      listPartitionReassignments in interface org.apache.kafka.controller.Controller

    • legacyAlterConfigs

      public CompletableFuture<Map<org.apache.kafka.common.config.ConfigResource, org.apache.kafka.common.requests.ApiError>> legacyAlterConfigs(org.apache.kafka.controller.ControllerRequestContext context, Map<org.apache.kafka.common.config.ConfigResource, Map<String,String>> newConfigs, boolean validateOnly)
      Specified by:
      legacyAlterConfigs in interface org.apache.kafka.controller.Controller

    • processBrokerHeartbeat

      public CompletableFuture<org.apache.kafka.metadata.BrokerHeartbeatReply> processBrokerHeartbeat(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.BrokerHeartbeatRequestData request)
      Specified by:
      processBrokerHeartbeat in interface org.apache.kafka.controller.Controller

    • registerBroker

      public CompletableFuture<org.apache.kafka.metadata.BrokerRegistrationReply> registerBroker(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.BrokerRegistrationRequestData request)
      Specified by:
      registerBroker in interface org.apache.kafka.controller.Controller

    • waitForReadyBrokers

      public CompletableFuture<Void> waitForReadyBrokers(int minBrokers)
      Specified by:
      waitForReadyBrokers in interface org.apache.kafka.controller.Controller

    • alterClientQuotas

      public CompletableFuture<Map<org.apache.kafka.common.quota.ClientQuotaEntity, org.apache.kafka.common.requests.ApiError>> alterClientQuotas(org.apache.kafka.controller.ControllerRequestContext context, Collection<org.apache.kafka.common.quota.ClientQuotaAlteration> quotaAlterations, boolean validateOnly)
      Specified by:
      alterClientQuotas in interface org.apache.kafka.controller.Controller

    • alterBrokerReplicaExclusions

      public CompletableFuture<org.apache.kafka.server.common.AlterReplicaExclusionsReply> alterBrokerReplicaExclusions(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterBrokerReplicaExclusionsRequestData request)
      Specified by:
      alterBrokerReplicaExclusions in interface org.apache.kafka.controller.Controller

    • describeBrokerReplicaExclusions

      public CompletableFuture<Map<Integer,String>> describeBrokerReplicaExclusions(org.apache.kafka.controller.ControllerRequestContext context)
      Specified by:
      describeBrokerReplicaExclusions in interface org.apache.kafka.controller.Controller

    • alterBrokerHealth

      public CompletableFuture<org.apache.kafka.common.message.AlterBrokerHealthResponseData> alterBrokerHealth(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AlterBrokerHealthRequestData request)
      Specified by:
      alterBrokerHealth in interface org.apache.kafka.controller.Controller

    • describeBrokerHealth

      public CompletableFuture<org.apache.kafka.common.message.DescribeBrokerHealthResponseData> describeBrokerHealth(org.apache.kafka.controller.ControllerRequestContext context)
      Specified by:
      describeBrokerHealth in interface org.apache.kafka.controller.Controller

    • allocateProducerIds

      public CompletableFuture<org.apache.kafka.common.message.AllocateProducerIdsResponseData> allocateProducerIds(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AllocateProducerIdsRequestData request)
      Specified by:
      allocateProducerIds in interface org.apache.kafka.controller.Controller

    • updateFeatures

      public CompletableFuture<org.apache.kafka.common.message.UpdateFeaturesResponseData> updateFeatures(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.UpdateFeaturesRequestData request)
      Specified by:
      updateFeatures in interface org.apache.kafka.controller.Controller

    • createPartitions

      public CompletableFuture<List<org.apache.kafka.common.message.CreatePartitionsResponseData.CreatePartitionsTopicResult>> createPartitions(org.apache.kafka.controller.ControllerRequestContext context, List<org.apache.kafka.common.message.CreatePartitionsRequestData.CreatePartitionsTopic> topicList, boolean validateOnly)
      Specified by:
      createPartitions in interface org.apache.kafka.controller.Controller

    • registerController

      public CompletableFuture<Void> registerController(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.ControllerRegistrationRequestData request)
      Specified by:
      registerController in interface org.apache.kafka.controller.Controller

    • beginShutdown

      public void beginShutdown()
      Specified by:
      beginShutdown in interface org.apache.kafka.controller.Controller

    • setActive

      public void setActive(boolean active)

    • curClaimEpoch

      public int curClaimEpoch()
      Specified by:
      curClaimEpoch in interface org.apache.kafka.controller.Controller

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface org.apache.kafka.controller.Controller

    • assignReplicasToDirs

      public CompletableFuture<org.apache.kafka.common.message.AssignReplicasToDirsResponseData> assignReplicasToDirs(org.apache.kafka.controller.ControllerRequestContext context, org.apache.kafka.common.message.AssignReplicasToDirsRequestData request)
      Specified by:
      assignReplicasToDirs in interface org.apache.kafka.controller.Controller