Tableflow Control Plane Auditable Event Methods on Confluent Cloud¶
Expand all examples | Collapse all examples
Confluent Cloud audit logs contain records of auditable events for Tableflow operations. When an auditable event occurs, a message is sent to the audit log and is stored as an audit log record.
The following sections describe the auditable event methods for the Tableflow control plane and can be used to identify and monitor Tableflow operations, such as enabling and disabling Tableflow on a topic, and enabling or disabling catalog integration.
Tableflow Topics auditable event methods¶
Included here are operations authenticating to a Flink region that generate
auditable event messages for the io.confluent.cloud/request event type.
| Method name | Action triggering an auditable event message |
|---|---|
| TableflowCreateTable | A request to create a Tableflow topic. |
| TableflowDeleteTable | A request to delete a Tableflow topic. |
| TableflowGetTable | A request to get the details of a Tableflow topic. |
| TableflowListTables | A request to list Tableflow topics. |
| TableflowUpdateTable | A request to update a Tableflow topic. |
Examples¶
TableflowCreateTable¶
The TableflowCreateTable event method is triggered by a request to create
a Tableflow topic. Examples of the TableflowCreateTable event method are
shown below for BYOB and Confluent Managed AWS Storage.
SUCCESS: Confluent Managed AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowCreateTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"config": {
"refresh_interval_ms": 21600000,
"retention_ms": 7776000000
},
"environment_id": {
"id": "env-1"
},
"lkc_id": {
"environment": "env-1",
"id": "lkc-1"
},
"name": "topic-1",
"storage_config": {
"kind": "Managed"
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
SUCCESS: BYOB AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowCreateTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"config": {
"refresh_interval_ms": 21600000,
"retention_ms": 7776000000
},
"environment_id": {
"id": "env-1"
},
"lkc_id": {
"environment": "env-1",
"id": "lkc-1"
},
"name": "topic-1",
"storage_config": {
"kind": "Managed"
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Internal server error
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowCreateTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"config": {
"refresh_interval_ms": 21600000,
"retention_ms": 7776000000
},
"environment_id": {
"id": "env-1"
},
"lkc_id": {
"environment": "env-1",
"id": "lkc-1"
},
"name": "topic-1",
"storage_config": {
"bucket_name": "bucket",
"bucket_region": "us-west-2",
"kind": "ByobAws",
"provider_integration_id": "provider-integration-id"
}
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "server_error",
"detail": "Internal Server Error: oops, something went wrong",
"id": "30303030303030303030303030303030",
"source": {},
"status": "500"
}
]
}
}
}
}
TableflowDeleteTable¶
The TableflowDeleteTable event method is triggered by a request to delete
a Tableflow topic.
SUCCESS: BYOB AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowDeleteTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "provider-integration-id"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"environment_id": "env-1",
"lkc_id": "lkc-1",
"name": "topic-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
SUCCESS: Confluent Managed AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowDeleteTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"environment_id": "env-1",
"lkc_id": "lkc-1",
"name": "topic-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Internal Server Error
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowGetTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"cluster_id": "lkc-1",
"environment_id": "env-1",
"name": "topic-1"
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "server_error",
"detail": "Internal Server Error: oops, something went wrong",
"id": "30303030303030303030303030303030",
"source": {},
"status": "500"
}
]
}
}
}
}
TableflowGetTable¶
The TableflowGetTable event method is triggered by a request to get the
details of a Tableflow topic.
SUCCESS: Confluent Managed AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowGetTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"cluster_id": "lkc-1",
"environment_id": "env-1",
"name": "topic-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Forbidden Access
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowGetTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"cluster_id": "lkc-1",
"environment_id": "env-1",
"name": "topic-1"
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "forbidden_access",
"detail": "Forbidden Access",
"id": "30303030303030303030303030303030",
"source": {},
"status": "403"
}
]
}
}
}
}
TableflowUpdateTable¶
The TableflowUpdateTable event method is triggered by a request to update
a Tableflow topic.
SUCCESS: Confluent Managed AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1/topic=topic-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowUpdateTable",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
},
{
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TOPIC",
"resourceId": "topic-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"name": "topic-1",
"spec": {
"config": {
"refresh_interval_ms": 3600000,
"retention_ms": 1000342350
},
"environment_id": {
"id": "env-1"
},
"lkc_id": {
"id": "lkc-1"
}
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
TableflowListTables¶
The TableflowListTables event method is triggered by a request to list
Tableflow topics.
SUCCESS: Confluent Managed AWS Storage
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/kafka-cluster=lkc-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "TableflowListTables",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "KAFKA_CLUSTER",
"resourceId": "lkc-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"cluster_id": "lkc-1",
"environment_id": "env-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
TableFlow Catalog Integration auditable event methods¶
Included here are operations that generate auditable event messages for the
io.confluent.tableflow.server/catalog event type.
| Method name | Action triggering an auditable event message |
|---|---|
| CreateTableflowCatalog | A request to create a TableFlow catalog integration. |
| DeleteTableFlowCatalog | A request to delete a TableFlow catalog integration. |
| GetTableFlowCatalog | A request to get the details of a TableFlow catalog integration. |
| ListTableFlowCatalog | A request to list TableFlow topics. |
| UpdateTableFlowCatalog | A request to update a TableFlow catalog integration. |
Examples¶
CreateTableflowCatalog¶
The CreateTableflowCatalog event method is triggered by a request
to create a TableFlow catalog integration. For Catalog integration, the
event is that a provider integration is mapped to the catalog integration.
SUCCESS
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "CreateTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "cspi-stgce89r7"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"spec": {
"cluster_lkc": {
"id": "lkc-1"
},
"config": {
"client_id": "",
"kind": "AwsGlue",
"provider_integration_id": "cspi-stgce89r7"
},
"environment": {
"id": "env-1"
}
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Internal server error
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "CreateTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"spec": {
"cluster_lkc": {
"id": "lkc-1"
},
"config": {
"client_id": "",
"kind": "AwsGlue",
"provider_integration_id": "cspi-stgce89r7"
},
"environment": {
"id": "env-1"
}
}
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "server_error",
"detail": "Internal Server Error: oops, something went wrong",
"id": "30303030303030303030303030303030",
"source": {},
"status": "500"
}
]
}
}
}
}
DeleteTableflowCatalog¶
The DeleteTableFlowCatalog event method is triggered by a request to delete
a TableFlow catalog integration, with the provider integration deactivated.
SUCCESS
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "DeleteTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "cspi-stgce89r7"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"environment_id": "env-1",
"id": "tci-1",
"lkc_id": "lkc-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Internal server error
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/tableflow-catalog=tci-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "DeleteTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"environment_id": "env-1",
"id": "tci-1",
"lkc_id": "lkc-1"
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "server_error",
"detail": "Internal Server Error: oops, something went wrong",
"id": "30303030303030303030303030303030",
"source": {},
"status": "500"
}
]
}
}
}
}
GetTableFlowCatalog¶
The GetTableFlowCatalog event method is triggered by a request to get the
details of a TableFlow catalog integration.
SUCCESS
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/tableflow-catalog=tci-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "GetTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"environment_id": "env-1",
"id": "tci-1",
"lkc_id": "lkc-1"
}
},
"result": {
"status": "SUCCESS"
}
}
}
FAILURE: Forbidden access
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1/tableflow-catalog=tci-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "GetTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "READ_ONLY",
"data": {
"environment_id": "env-1",
"id": "tci-1",
"lkc_id": "lkc-1"
}
},
"result": {
"status": "FAILURE",
"data": {
"errors": [
{
"code": "forbidden_access",
"detail": "Forbidden Access",
"id": "30303030303030303030303030303030",
"source": {},
"status": "403"
}
]
}
}
}
}
ListTableFlowCatalog¶
The ListTableFlowCatalog event method is triggered by a request to list
TableFlow topics.
SUCCESS
{ "specversion": "1.0", "id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee", "source": "crn://confluent.cloud/", "type": "io.confluent.cloud/request", "subject": "crn://confluent.cloud/organization=org-22/environment=env-1/cloud-cluster=lkc-1", "datacontenttype": "application/json", "dataschema": "https://confluent.io/internal/events/AuditLog.v2", "data": { "serviceName": "crn://confluent.cloud/service=cc-cts-api-service", "methodName": "ListTableFlowCatalog", "cloudResources": [ { "scope": { "resources": [ { "type": "ORGANIZATION", "resourceId": "org-22" }, { "type": "ENVIRONMENT", "resourceId": "env-1" } ] }, "resource": { "type": "CLOUD_CLUSTER", "resourceId": "lkc-1" } } ], "authenticationInfo": { "principal": { "confluentUser": { "resourceId": "u-abc123", "internal_id": "99" } }, "result": "SUCCESS", "identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123" }, "requestMetadata": { "requestId": [ "30303030303030303030303030303030" ], "clientAddress": [ { "ip": "127.0.0.1" } ] }, "request": { "accessType": "READ_ONLY", "data": { "environment_id": "env-1", "lkc_id": "lkc-1" } }, "result": { "status": "SUCCESS" } } }UpdateTableFlowCatalog¶
The UpdateTableFlowCatalog event method is triggered by a request to update
a TableFlow catalog integration.
SUCCESS
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "UpdateTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "cspi-stgce89r7"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"id": "tci-1",
"spec": {
"cluster_lkc": {
"id": "lkc-1"
},
"config": {
"client_id": "",
"kind": "AwsGlue",
"provider_integration_id": "cspi-stgce89r7"
},
"environment": {
"id": "env-1"
}
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
</details>
SUCCESS: New provider integration
{
"specversion": "1.0",
"id": "aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee",
"source": "crn://confluent.cloud/",
"type": "io.confluent.cloud/request",
"subject": "crn://confluent.cloud/organization=org-22/environment=env-1",
"datacontenttype": "application/json",
"dataschema": "https://confluent.io/internal/events/AuditLog.v2",
"data": {
"serviceName": "crn://confluent.cloud/service=cc-cts-api-service",
"methodName": "UpdateTableFlowCatalog",
"cloudResources": [
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
},
{
"type": "CLOUD_CLUSTER",
"resourceId": "lkc-1"
}
]
},
"resource": {
"type": "TABLEFLOW_CATALOG",
"resourceId": "tci-1"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "cspi-stgce1233"
}
},
{
"scope": {
"resources": [
{
"type": "ORGANIZATION",
"resourceId": "org-22"
},
{
"type": "ENVIRONMENT",
"resourceId": "env-1"
}
]
},
"resource": {
"type": "PROVIDER_INTEGRATION",
"resourceId": "cspi-stgce89r7"
}
}
],
"authenticationInfo": {
"principal": {
"confluentUser": {
"resourceId": "u-abc123",
"internal_id": "99"
}
},
"result": "SUCCESS",
"identity": "crn://confluent.cloud/organization=org-22/identity-provider=Confluent/identity=u-abc123"
},
"requestMetadata": {
"requestId": [
"30303030303030303030303030303030"
],
"clientAddress": [
{
"ip": "127.0.0.1"
}
]
},
"request": {
"accessType": "MODIFICATION",
"data": {
"id": "tci-1",
"spec": {
"cluster_lkc": {
"id": "lkc-1"
},
"config": {
"client_id": "",
"kind": "AwsGlue",
"provider_integration_id": "cspi-stgce1233"
},
"environment": {
"id": "env-1"
}
}
}
},
"result": {
"status": "SUCCESS"
}
}
}
</details>