Add Managed Kafka Connect cluster code samples

[salmany]

Description

• Adds sample code for creating, deleting, getting, listing and updating Managed Kafka Connect clusters

Fixes https://b.corp.google.com/issues/430087669

Note: Before submitting a pull request, please open an issue for discussion if you are not associated with Google.

Checklist

• I have followed Sample Guidelines from AUTHORING_GUIDE.MD
• README is updated to include all relevant information
• Tests pass: nox -s py-3.9 (see Test Environment Setup)
• Lint pass: nox -s lint (see Test Environment Setup)
• These samples need a new API enabled in testing projects to pass (let us know which ones)
• These samples need a new/updated env vars in testing projects set to pass (let us know which ones)
• This sample adds a new sample directory, and I updated the CODEOWNERS file with the codeowners for this sample
• This sample adds a new Product API, and I updated the Blunderbuss issue/PR auto-assigner with the codeowners for this sample
• Please merge this PR for me once it is approved

[gemini-code-assist]

Summary of Changes

Hello @salmany, I'm Gemini Code Assist¹! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed!

This pull request significantly expands the sample code coverage for Google Cloud's Managed Kafka Connect service. It provides developers with practical, runnable examples for managing Connect clusters programmatically, which will greatly aid in adoption and understanding of the service. The changes include new sample files for various CRUD operations and their corresponding tests, along with a minor dependency update.

Highlights

• New Managed Kafka Connect Samples: This PR introduces a comprehensive set of Python code samples for interacting with Managed Kafka Connect clusters, covering common operations like creation, retrieval, listing, updating, and deletion.
• Dedicated Test Suite: A new test file (clusters_test.py) has been added to provide robust unit tests for all the newly introduced Managed Kafka Connect cluster operations, ensuring their correctness and functionality.
• Dependency Update: The google-cloud-managedkafka library dependency has been updated from version 0.1.5 to 0.1.12 in requirements.txt to align with the latest API capabilities and fixes.

Using Gemini Code Assist

The full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips.

Invoking Gemini

You can request assistance from Gemini at any point in your pull request via creating an issue comment (i.e. comment on the pull request page) using either /gemini <command> or @gemini-code-assist <command>. Below is a summary of the supported commands.

Feature	Command	Description
Code Review	/gemini review	Performs a code review for the current pull request in its current state.
Pull Request Summary	/gemini summary	Provides a summary of the current pull request in its current state.
Comment	@gemini-code-assist	Responds in comments when explicitly tagged, both in issue comments and review comments.
Help	/gemini help	Displays a list of available commands.

Customization

To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a .gemini/ folder in the base of the repository. Detailed instructions can be found here.

Limitations & Feedback

Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments or fill out our survey to provide feedback.

You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension.

Footnotes

1. Review the Privacy Notices, Generative AI Prohibited Use Policy, Terms of Service, and learn how to configure Gemini Code Assist in GitHub here. Gemini can make mistakes, so double check it and use code with caution. ↩

[gemini-code-assist]

Code Review

This pull request introduces new code samples for managing Kafka Connect clusters. The changes are well-implemented and cover a good range of functionalities.

My review focuses on improving the robustness and maintainability of the new samples. Key suggestions include:

• Replacing the deprecated .message attribute on exceptions with str(e).
• Adding timeouts to long-running operations to prevent scripts from hanging.
• Incorporating error handling for API calls to manage potential failures gracefully.
• A minor change for code clarity in a TODO comment.

These adjustments will make the samples more reliable and easier for developers to use.

[snippet-bot]

Here is the summary of changes.

You are about to add 5 region tags.

• managedkafka/snippets/connect/clusters/create_connect_cluster.py:41, tag managedkafka_create_connect_cluster
• managedkafka/snippets/connect/clusters/delete_connect_cluster.py:33, tag managedkafka_delete_connect_cluster
• managedkafka/snippets/connect/clusters/get_connect_cluster.py:32, tag managedkafka_get_connect_cluster
• managedkafka/snippets/connect/clusters/list_connect_clusters.py:27, tag managedkafka_list_connect_clusters
• managedkafka/snippets/connect/clusters/update_connect_cluster.py:32, tag managedkafka_update_connect_cluster

---

This comment is generated by snippet-bot.
If you find problems with this result, please file an issue at:
https://github.com/googleapis/repo-automation-bots/issues.
To update this comment, add snippet-bot:force-run label or use the checkbox below:

• Refresh this comment