- 필수 기능
- 시작하기
- Glossary
- 표준 속성
- Guides
- Agent
- 통합
- 개방형텔레메트리
- 개발자
- Administrator's Guide
- API
- Datadog Mobile App
- CoScreen
- Cloudcraft
- 앱 내
- 서비스 관리
- 인프라스트럭처
- 애플리케이션 성능
- APM
- Continuous Profiler
- 스팬 시각화
- 데이터 스트림 모니터링
- 데이터 작업 모니터링
- 디지털 경험
- 소프트웨어 제공
- 보안
- AI Observability
- 로그 관리
- 관리
Manage your Datadog Confluent Cloud integration accounts and account resources directly through the Datadog API. See the Confluent Cloud page for more information.
PATCH https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Update a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
Confluent payload
항목
유형
설명
data [required]
object
JSON:API request for updating a Confluent resource.
attributes [required]
object
Attributes object for updating a Confluent resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with a Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource-id-123",
"type": "confluent-cloud-resources"
}
}
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Update resource in Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
body := datadogV2.ConfluentResourceRequest{
Data: datadogV2.ConfluentResourceRequestData{
Attributes: datadogV2.ConfluentResourceRequestAttributes{
EnableCustomMetrics: datadog.PtrBool(false),
ResourceType: "kafka",
Tags: []string{
"myTag",
"myTag2:myValue",
},
},
Id: "resource-id-123",
Type: datadogV2.CONFLUENTRESOURCETYPE_CONFLUENT_CLOUD_RESOURCES,
},
}
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.UpdateConfluentResource(ctx, "account_id", "resource_id", body)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.UpdateConfluentResource`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.UpdateConfluentResource`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Get a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Get resource from Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.GetConfluentResource(ctx, "account_id", "resource_id")
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.GetConfluentResource`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.GetConfluentResource`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
DELETE https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Delete a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
OK
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Delete resource from Confluent account returns "OK" response
package main
import (
"context"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
r, err := api.DeleteConfluentResource(ctx, "account_id", "resource_id")
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.DeleteConfluentResource`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
POST https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources
Create a Confluent resource for the account associated with the provided ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
Confluent payload
항목
유형
설명
data [required]
object
JSON:API request for updating a Confluent resource.
attributes [required]
object
Attributes object for updating a Confluent resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with a Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
],
"enable_custom_metrics": false
},
"id": "exampleconfluentcloud",
"type": "confluent-cloud-resources"
}
}
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Add resource to Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
// there is a valid "confluent_account" in the system
ConfluentAccountDataID := os.Getenv("CONFLUENT_ACCOUNT_DATA_ID")
body := datadogV2.ConfluentResourceRequest{
Data: datadogV2.ConfluentResourceRequestData{
Attributes: datadogV2.ConfluentResourceRequestAttributes{
ResourceType: "kafka",
Tags: []string{
"myTag",
"myTag2:myValue",
},
EnableCustomMetrics: datadog.PtrBool(false),
},
Id: "exampleconfluentcloud",
Type: datadogV2.CONFLUENTRESOURCETYPE_CONFLUENT_CLOUD_RESOURCES,
},
}
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.CreateConfluentResource(ctx, ConfluentAccountDataID, body)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.CreateConfluentResource`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.CreateConfluentResource`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources
Get a Confluent resource for the account associated with the provided ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
Response schema when interacting with a list of Confluent resources.
항목
유형
설명
data
[object]
The JSON:API data attribute.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": [
{
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
]
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// List Confluent Account resources returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.ListConfluentResource(ctx, "account_id")
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.ListConfluentResource`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.ListConfluentResource`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
PATCH https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Update the Confluent account with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
Confluent payload
항목
유형
설명
data [required]
object
Data object for updating a Confluent account.
attributes [required]
object
Attributes object for updating a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
api_secret [required]
string
The API secret associated with your Confluent account.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"api_secret": "update-secret",
"tags": [
"updated_tag:val"
]
},
"type": "confluent-cloud-accounts"
}
}
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Update Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
// there is a valid "confluent_account" in the system
ConfluentAccountDataAttributesAPIKey := os.Getenv("CONFLUENT_ACCOUNT_DATA_ATTRIBUTES_API_KEY")
ConfluentAccountDataID := os.Getenv("CONFLUENT_ACCOUNT_DATA_ID")
body := datadogV2.ConfluentAccountUpdateRequest{
Data: datadogV2.ConfluentAccountUpdateRequestData{
Attributes: datadogV2.ConfluentAccountUpdateRequestAttributes{
ApiKey: ConfluentAccountDataAttributesAPIKey,
ApiSecret: "update-secret",
Tags: []string{
"updated_tag:val",
},
},
Type: datadogV2.CONFLUENTACCOUNTTYPE_CONFLUENT_CLOUD_ACCOUNTS,
},
}
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.UpdateConfluentAccount(ctx, ConfluentAccountDataID, body)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.UpdateConfluentAccount`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.UpdateConfluentAccount`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Get the Confluent account with the provided account ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Get Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
// there is a valid "confluent_account" in the system
ConfluentAccountDataID := os.Getenv("CONFLUENT_ACCOUNT_DATA_ID")
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.GetConfluentAccount(ctx, ConfluentAccountDataID)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.GetConfluentAccount`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.GetConfluentAccount`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
DELETE https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Delete a Confluent account with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Delete Confluent account returns "OK" response
package main
import (
"context"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
// there is a valid "confluent_account" in the system
ConfluentAccountDataID := os.Getenv("CONFLUENT_ACCOUNT_DATA_ID")
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
r, err := api.DeleteConfluentAccount(ctx, ConfluentAccountDataID)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.DeleteConfluentAccount`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
POST https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accountshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts
Create a Confluent account.
This endpoint requires the manage_integrations
permission.
Confluent payload
항목
유형
설명
data [required]
object
The data body for adding a Confluent account.
attributes [required]
object
Attributes associated with the account creation request.
api_key [required]
string
The API key associated with your Confluent account.
api_secret [required]
string
The API secret associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with a Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"api_secret": "test-api-secret-123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource-id-123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"type": "confluent-cloud-accounts"
}
}
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// Add Confluent account returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
body := datadogV2.ConfluentAccountCreateRequest{
Data: datadogV2.ConfluentAccountCreateRequestData{
Attributes: datadogV2.ConfluentAccountCreateRequestAttributes{
ApiKey: "TESTAPIKEY123",
ApiSecret: "test-api-secret-123",
Resources: []datadogV2.ConfluentAccountResourceAttributes{
{
EnableCustomMetrics: datadog.PtrBool(false),
Id: datadog.PtrString("resource-id-123"),
ResourceType: "kafka",
Tags: []string{
"myTag",
"myTag2:myValue",
},
},
},
Tags: []string{
"myTag",
"myTag2:myValue",
},
},
Type: datadogV2.CONFLUENTACCOUNTTYPE_CONFLUENT_CLOUD_ACCOUNTS,
},
}
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.CreateConfluentAccount(ctx, body)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.CreateConfluentAccount`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.CreateConfluentAccount`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accountshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts
List Confluent accounts.
This endpoint requires the integrations_read
permission.
OK
Confluent account returned by the API.
항목
유형
설명
data
[object]
The Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": [
{
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
]
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
// List Confluent accounts returns "OK" response
package main
import (
"context"
"encoding/json"
"fmt"
"os"
"github.com/DataDog/datadog-api-client-go/v2/api/datadog"
"github.com/DataDog/datadog-api-client-go/v2/api/datadogV2"
)
func main() {
ctx := datadog.NewDefaultContext(context.Background())
configuration := datadog.NewConfiguration()
apiClient := datadog.NewAPIClient(configuration)
api := datadogV2.NewConfluentCloudApi(apiClient)
resp, r, err := api.ListConfluentAccount(ctx)
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfluentCloudApi.ListConfluentAccount`: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
responseContent, _ := json.MarshalIndent(resp, "", " ")
fmt.Fprintf(os.Stdout, "Response from `ConfluentCloudApi.ListConfluentAccount`:\n%s\n", responseContent)
}
First install the library and its dependencies and then save the example to main.go
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" go run "main.go"