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.cloud/request 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>

Tableflow Control Plane Auditable Event Methods on Confluent Cloud

Tableflow Topics auditable event methods

Examples

TableflowCreateTable

TableflowDeleteTable

TableflowGetTable

TableflowUpdateTable

TableflowListTables

Tableflow Catalog Integration Auditable Event Methods

Examples

CreateTableflowCatalog

DeleteTableflowCatalog

GetTableFlowCatalog

ListTableFlowCatalog

UpdateTableFlowCatalog

Related content