Skip to main content
Google Cloud Documentation
Technology areas
  • AI and ML
  • Application development
  • Application hosting
  • Compute
  • Data analytics and pipelines
  • Databases
  • Distributed, hybrid, and multicloud
  • Generative AI
  • Industry solutions
  • Networking
  • Observability and monitoring
  • Security
  • Storage
Cross-product tools
  • Access and resources management
  • Costs and usage management
  • Infrastructure as code
  • Migration
  • SDK, languages, frameworks, and tools
/
Console
  • English
  • Deutsch
  • Español – América Latina
  • Français
  • Português – Brasil
  • 中文 – 简体
  • 日本語
  • 한국어
Sign in
  • C++
  • Client libraries
Start free
Overview Guides Reference Samples
Google Cloud Documentation
  • Technology areas
    • More
    • Overview
    • Guides
    • Reference
    • Samples
  • Cross-product tools
    • More
  • Console
  • Overview
  • Library reference docs
  • Apache Kafka for BigQuery API C++ Client Library
  • In-Depth Topics
    • Environment Variables
    • How to Override the Authentication Credentials
    • How to Override the Default Endpoint
    • Override Retry, Backoff, and Idempotency Policies
    • Override managedkafka_v1::ManagedKafkaClient Retry Policies
  • Modules
    • Apache Kafka for BigQuery API Configuration Options
  • Namespaces
    • google::cloud::managedkafka_v1
      • Overview
      • Classes
        • ManagedKafkaClient
          • Overview
          • Constructors
            • ManagedKafkaClient(ManagedKafkaClient const &)
            • ManagedKafkaClient(ManagedKafkaClient &&)
            • ManagedKafkaClient(std::shared_ptr< ManagedKafkaConnection >, Options)
          • Operators
            • operator=(ManagedKafkaClient const &)
            • operator=(ManagedKafkaClient &&)
            • operator==(ManagedKafkaClient const &, ManagedKafkaClient const &)
            • operator!=(ManagedKafkaClient const &, ManagedKafkaClient const &)
          • Functions
            • ListClusters(std::string const &, Options)
            • ListClusters(google::cloud::managedkafka::v1::ListClustersRequest, Options)
            • GetCluster(std::string const &, Options)
            • GetCluster(google::cloud::managedkafka::v1::GetClusterRequest const &, Options)
            • CreateCluster(std::string const &, google::cloud::managedkafka::v1::Cluster const &, std::string const &, Options)
            • CreateCluster(ExperimentalTag, NoAwaitTag, std::string const &, google::cloud::managedkafka::v1::Cluster const &, std::string const &, Options)
            • CreateCluster(google::cloud::managedkafka::v1::CreateClusterRequest const &, Options)
            • CreateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::CreateClusterRequest const &, Options)
            • CreateCluster(ExperimentalTag, google::longrunning::Operation const &, Options)
            • UpdateCluster(google::cloud::managedkafka::v1::Cluster const &, google::protobuf::FieldMask const &, Options)
            • UpdateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::Cluster const &, google::protobuf::FieldMask const &, Options)
            • UpdateCluster(google::cloud::managedkafka::v1::UpdateClusterRequest const &, Options)
            • UpdateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::UpdateClusterRequest const &, Options)
            • UpdateCluster(ExperimentalTag, google::longrunning::Operation const &, Options)
            • DeleteCluster(std::string const &, Options)
            • DeleteCluster(ExperimentalTag, NoAwaitTag, std::string const &, Options)
            • DeleteCluster(google::cloud::managedkafka::v1::DeleteClusterRequest const &, Options)
            • DeleteCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::DeleteClusterRequest const &, Options)
            • DeleteCluster(ExperimentalTag, google::longrunning::Operation const &, Options)
            • ListTopics(std::string const &, Options)
            • ListTopics(google::cloud::managedkafka::v1::ListTopicsRequest, Options)
            • GetTopic(std::string const &, Options)
            • GetTopic(google::cloud::managedkafka::v1::GetTopicRequest const &, Options)
            • CreateTopic(std::string const &, google::cloud::managedkafka::v1::Topic const &, std::string const &, Options)
            • CreateTopic(google::cloud::managedkafka::v1::CreateTopicRequest const &, Options)
            • UpdateTopic(google::cloud::managedkafka::v1::Topic const &, google::protobuf::FieldMask const &, Options)
            • UpdateTopic(google::cloud::managedkafka::v1::UpdateTopicRequest const &, Options)
            • DeleteTopic(std::string const &, Options)
            • DeleteTopic(google::cloud::managedkafka::v1::DeleteTopicRequest const &, Options)
            • ListConsumerGroups(std::string const &, Options)
            • ListConsumerGroups(google::cloud::managedkafka::v1::ListConsumerGroupsRequest, Options)
            • GetConsumerGroup(std::string const &, Options)
            • GetConsumerGroup(google::cloud::managedkafka::v1::GetConsumerGroupRequest const &, Options)
            • UpdateConsumerGroup(google::cloud::managedkafka::v1::ConsumerGroup const &, google::protobuf::FieldMask const &, Options)
            • UpdateConsumerGroup(google::cloud::managedkafka::v1::UpdateConsumerGroupRequest const &, Options)
            • DeleteConsumerGroup(std::string const &, Options)
            • DeleteConsumerGroup(google::cloud::managedkafka::v1::DeleteConsumerGroupRequest const &, Options)
        • ManagedKafkaConnection
          • Overview
          • Functions
            • virtual options()
            • virtual ListClusters(google::cloud::managedkafka::v1::ListClustersRequest)
            • virtual GetCluster(google::cloud::managedkafka::v1::GetClusterRequest const &)
            • virtual CreateCluster(google::cloud::managedkafka::v1::CreateClusterRequest const &)
            • virtual CreateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::CreateClusterRequest const &)
            • virtual CreateCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual UpdateCluster(google::cloud::managedkafka::v1::UpdateClusterRequest const &)
            • virtual UpdateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::UpdateClusterRequest const &)
            • virtual UpdateCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual DeleteCluster(google::cloud::managedkafka::v1::DeleteClusterRequest const &)
            • virtual DeleteCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::DeleteClusterRequest const &)
            • virtual DeleteCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual ListTopics(google::cloud::managedkafka::v1::ListTopicsRequest)
            • virtual GetTopic(google::cloud::managedkafka::v1::GetTopicRequest const &)
            • virtual CreateTopic(google::cloud::managedkafka::v1::CreateTopicRequest const &)
            • virtual UpdateTopic(google::cloud::managedkafka::v1::UpdateTopicRequest const &)
            • virtual DeleteTopic(google::cloud::managedkafka::v1::DeleteTopicRequest const &)
            • virtual ListConsumerGroups(google::cloud::managedkafka::v1::ListConsumerGroupsRequest)
            • virtual GetConsumerGroup(google::cloud::managedkafka::v1::GetConsumerGroupRequest const &)
            • virtual UpdateConsumerGroup(google::cloud::managedkafka::v1::UpdateConsumerGroupRequest const &)
            • virtual DeleteConsumerGroup(google::cloud::managedkafka::v1::DeleteConsumerGroupRequest const &)
        • ManagedKafkaConnectionIdempotencyPolicy
          • Overview
          • Functions
            • virtual clone() const
            • virtual ListClusters(google::cloud::managedkafka::v1::ListClustersRequest)
            • virtual GetCluster(google::cloud::managedkafka::v1::GetClusterRequest const &)
            • virtual CreateCluster(google::cloud::managedkafka::v1::CreateClusterRequest const &)
            • virtual UpdateCluster(google::cloud::managedkafka::v1::UpdateClusterRequest const &)
            • virtual DeleteCluster(google::cloud::managedkafka::v1::DeleteClusterRequest const &)
            • virtual ListTopics(google::cloud::managedkafka::v1::ListTopicsRequest)
            • virtual GetTopic(google::cloud::managedkafka::v1::GetTopicRequest const &)
            • virtual CreateTopic(google::cloud::managedkafka::v1::CreateTopicRequest const &)
            • virtual UpdateTopic(google::cloud::managedkafka::v1::UpdateTopicRequest const &)
            • virtual DeleteTopic(google::cloud::managedkafka::v1::DeleteTopicRequest const &)
            • virtual ListConsumerGroups(google::cloud::managedkafka::v1::ListConsumerGroupsRequest)
            • virtual GetConsumerGroup(google::cloud::managedkafka::v1::GetConsumerGroupRequest const &)
            • virtual UpdateConsumerGroup(google::cloud::managedkafka::v1::UpdateConsumerGroupRequest const &)
            • virtual DeleteConsumerGroup(google::cloud::managedkafka::v1::DeleteConsumerGroupRequest const &)
        • ManagedKafkaLimitedErrorCountRetryPolicy
          • Overview
          • Constructors
            • ManagedKafkaLimitedErrorCountRetryPolicy(int)
            • ManagedKafkaLimitedErrorCountRetryPolicy(ManagedKafkaLimitedErrorCountRetryPolicy &&)
            • ManagedKafkaLimitedErrorCountRetryPolicy(ManagedKafkaLimitedErrorCountRetryPolicy const &)
          • Functions
            • maximum_failures() const
            • virtual OnFailure(Status const &)
            • virtual IsExhausted() const
            • virtual IsPermanentFailure(Status const &) const
            • virtual clone() const
          • Types
            • BaseType
        • ManagedKafkaLimitedTimeRetryPolicy
          • Overview
          • Constructors
            • ManagedKafkaLimitedTimeRetryPolicy(std::chrono::duration< DurationRep, DurationPeriod >)
            • ManagedKafkaLimitedTimeRetryPolicy(ManagedKafkaLimitedTimeRetryPolicy &&)
            • ManagedKafkaLimitedTimeRetryPolicy(ManagedKafkaLimitedTimeRetryPolicy const &)
          • Functions
            • maximum_duration() const
            • virtual OnFailure(Status const &)
            • virtual IsExhausted() const
            • virtual IsPermanentFailure(Status const &) const
            • virtual clone() const
          • Types
            • BaseType
        • ManagedKafkaRetryPolicy
          • Overview
          • Functions
            • clone() const
            • OnFailure(Status const &)
            • OnFailure(Status const &)
            • IsExhausted() const
            • IsExhausted() const
            • IsPermanentFailure(Status const &) const
            • IsPermanentFailure(Status const &) const
      • Structs
        • ManagedKafkaBackoffPolicyOption
          • Overview
          • Types
            • Type
        • ManagedKafkaConnectionIdempotencyPolicyOption
          • Overview
          • Types
            • Type
        • ManagedKafkaPollingPolicyOption
          • Overview
          • Types
            • Type
        • ManagedKafkaRetryPolicyOption
          • Overview
          • Types
            • Type
      • Functions
        • MakeManagedKafkaConnection(Options)
        • MakeDefaultManagedKafkaConnectionIdempotencyPolicy()
    • google::cloud::managedkafka_v1_mocks
      • Overview
      • Classes
        • MockManagedKafkaConnection
          • Overview
          • Functions
            • virtual options()
            • virtual ListClusters(google::cloud::managedkafka::v1::ListClustersRequest)
            • virtual GetCluster(google::cloud::managedkafka::v1::GetClusterRequest const &)
            • virtual CreateCluster(google::cloud::managedkafka::v1::CreateClusterRequest const &)
            • virtual CreateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::CreateClusterRequest const &)
            • virtual CreateCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual UpdateCluster(google::cloud::managedkafka::v1::UpdateClusterRequest const &)
            • virtual UpdateCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::UpdateClusterRequest const &)
            • virtual UpdateCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual DeleteCluster(google::cloud::managedkafka::v1::DeleteClusterRequest const &)
            • virtual DeleteCluster(ExperimentalTag, NoAwaitTag, google::cloud::managedkafka::v1::DeleteClusterRequest const &)
            • virtual DeleteCluster(ExperimentalTag, google::longrunning::Operation const &)
            • virtual ListTopics(google::cloud::managedkafka::v1::ListTopicsRequest)
            • virtual GetTopic(google::cloud::managedkafka::v1::GetTopicRequest const &)
            • virtual CreateTopic(google::cloud::managedkafka::v1::CreateTopicRequest const &)
            • virtual UpdateTopic(google::cloud::managedkafka::v1::UpdateTopicRequest const &)
            • virtual DeleteTopic(google::cloud::managedkafka::v1::DeleteTopicRequest const &)
            • virtual ListConsumerGroups(google::cloud::managedkafka::v1::ListConsumerGroupsRequest)
            • virtual GetConsumerGroup(google::cloud::managedkafka::v1::GetConsumerGroupRequest const &)
            • virtual UpdateConsumerGroup(google::cloud::managedkafka::v1::UpdateConsumerGroupRequest const &)
            • virtual DeleteConsumerGroup(google::cloud::managedkafka::v1::DeleteConsumerGroupRequest const &)
  • AI and ML
  • Application development
  • Application hosting
  • Compute
  • Data analytics and pipelines
  • Databases
  • Distributed, hybrid, and multicloud
  • Generative AI
  • Industry solutions
  • Networking
  • Observability and monitoring
  • Security
  • Storage
  • Access and resources management
  • Costs and usage management
  • Infrastructure as code
  • Migration
  • SDK, languages, frameworks, and tools
  • Home
  • Technology areas
  • C++
  • Client libraries

Namespace google::cloud::managedkafka_v1_mocks (2.26.0) Stay organized with collections Save and categorize content based on your preferences.

  • 2.46.0-rc
  • 2.45.0 (latest)
  • 2.44.0
  • 2.43.0
  • 2.42.0
  • 2.41.0
  • 2.40.0
  • 2.39.0
  • 2.38.0
  • 2.37.0
  • 2.36.0
  • 2.35.0
  • 2.34.0
  • 2.33.0
  • 2.32.0
  • 2.31.0
  • 2.30.0
  • 2.29.0
  • 2.28.0
  • 2.27.0
  • 2.26.0

Classes

MockManagedKafkaConnection

A class to mock ManagedKafkaConnection.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025-12-17 UTC.

  • Products and pricing

    • See all products
    • Google Cloud pricing
    • Google Cloud Marketplace
    • Contact sales
  • Support

    • Community forums
    • Support
    • Release Notes
    • System status
  • Resources

    • GitHub
    • Getting Started with Google Cloud
    • Code samples
    • Cloud Architecture Center
    • Training and Certification
  • Engage

    • Blog
    • Events
    • X (Twitter)
    • Google Cloud on YouTube
    • Google Cloud Tech on YouTube
  • About Google
  • Privacy
  • Site terms
  • Google Cloud terms
  • Manage cookies
  • Our third decade of climate action: join us
  • Sign up for the Google Cloud newsletter Subscribe
  • English
  • Deutsch
  • Español – América Latina
  • Français
  • Português – Brasil
  • 中文 – 简体
  • 日本語
  • 한국어