An managed Apache Kafka cluster is designed to be highly fault-tolerant and scalable, allowing large volumes of data to be ingested, stored, and processed in real-time. By distributing data across multiple brokers, Kafka achieves high throughput and low latency, making it suitable for applications requiring real-time data processing and analytics.
This API client was generated by the OpenAPI Generator project. By using the OpenAPI-spec from a remote server, you can easily generate an API client.
- API version: 1.7.1
- Package version: 1.1.2
- Build package: org.openapitools.codegen.languages.GoClientCodegen For more information, please visit https://docs.ionos.com/support/general-information/contact-information
Install the following dependencies:
go get github.com/stretchr/testify/assert
go get golang.org/x/oauth2
go get golang.org/x/net/context
go get github.com/antihax/optional
Put the package under your project folder and add the following in import:
import "./ionoscloud"
All available server URLs are:
- https://kafka.de-fra.ionos.com - Production de-fra
- https://kafka.de-txl.ionos.com - Production de-txl
- https://kafka.es-vit.ionos.com - Production es-vit
- https://kafka.gb-lhr.ionos.com - Production gb-lhr
- https://kafka.us-ewr.ionos.com - Production us-ewr
- https://kafka.us-las.ionos.com - Production us-las
- https://kafka.us-mci.ionos.com - Production us-mci
- https://kafka.fr-par.ionos.com - Production fr-par
By default, https://kafka.de-fra.ionos.com is used, however this can be overriden at authentication, either
by setting the IONOS_API_URL
environment variable or by specifying the hostUrl
parameter when
initializing the sdk client.
The username and password or the authentication token can be manually specified when initializing the sdk client:
client := ionoscloud.NewAPIClient(ionoscloud.NewConfiguration(username, password, token, hostUrl))
Environment variables can also be used. The sdk uses the following variables:
- IONOS_TOKEN - login via token. This is the recommended way to authenticate.
- IONOS_USERNAME - to specify the username used to login
- IONOS_PASSWORD - to specify the password
- IONOS_API_URL - to specify the API server URL
In this case, the client configuration needs to be initialized using NewConfigurationFromEnv()
.
client := ionoscloud.NewAPIClient(ionoscloud.NewConfigurationFromEnv())
All URIs are relative to https://kafka.de-fra.ionos.com
API Endpoints table
Class | Method | HTTP request | Description |
---|---|---|---|
ClustersApi | ClustersDelete | Delete /clusters/{clusterId} | Delete Cluster |
ClustersApi | ClustersFindById | Get /clusters/{clusterId} | Retrieve Cluster |
ClustersApi | ClustersGet | Get /clusters | Retrieve all Clusters |
ClustersApi | ClustersPost | Post /clusters | Create Cluster |
TopicsApi | ClustersTopicsDelete | Delete /clusters/{clusterId}/topics/{topicId} | Delete Topic |
TopicsApi | ClustersTopicsFindById | Get /clusters/{clusterId}/topics/{topicId} | Retrieve Topic |
TopicsApi | ClustersTopicsGet | Get /clusters/{clusterId}/topics | Retrieve all Topics |
TopicsApi | ClustersTopicsPost | Post /clusters/{clusterId}/topics | Create Topic |
UsersApi | ClustersUsersAccessGet | Get /clusters/{clusterId}/users/{userId}/access | Retrieve Kafka User with credentials. |
UsersApi | ClustersUsersGet | Get /clusters/{clusterId}/users | Retrieve all Users |
All URIs are relative to https://kafka.de-fra.ionos.com
API models list
- Cluster
- ClusterCreate
- ClusterMetadata
- ClusterMetadataAllOf
- ClusterRead
- ClusterReadList
- ClusterReadListAllOf
- Error
- ErrorMessages
- KafkaClusterConnection
- Links
- Metadata
- Pagination
- ResourceMetadata
- ResourceState
- Topic
- TopicCreate
- TopicLogRetention
- TopicRead
- TopicReadList
- TopicReadListAllOf
- User
- UserAccessMetadata
- UserAccessMetadataAllOf
- UserRead
- UserReadAccess
- UserReadList
- UserReadListAllOf