Connector Auditable Event Methods on Confluent Cloud

Auditable event methods for the resource type CONNECTOR are triggered by operations on connectors (managed and custom) that send event messages to the audit log cluster and store them as event records in an Apache Kafka® topic. For more information about audit log records, see Audit Log Event Records.

Method name	Action triggering an auditable event message
CreateConnector	A request to create a connector.
CreateOrUpdateConnector	A request to update an existing connector with the provided configuration and, if a connector with the given name doesn’t exist, a request to create a connector with the provided configuration.
DeleteConnector	A request to delete a connector.
GetConnector	A request for a query of connector details.
GetConnectors	A request for a query of a list of all connectors.
PauseConnector	A request to pause a connector.
ResumeConnector	A request to resume a paused connector.

CreateConnector

The CreateConnector event is generated by a request to create a connector. It sends an event message that is saved in the audit log as an event record.

To view example event messages, expand the following dropdowns:

Success

{
  "specversion": "1.0",
  "id": "ea82b76b-af6f-4dbb-a939-266232a0cc98",
  "source": "crn://confluent.cloud/",
  "type": "io.confluent.cloud/request",
  "datacontenttype": "application/json",
  "subject": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-12j2w5/connector=lcc-pkdrjy",
  "time": "2021-10-20T20:00:56.417826232Z",
  "data": {
    "serviceName": "crn://confluent.cloud/",
    "methodName": "CreateConnector",
    "cloudResources": [
      {
        "scope": {
          "resources": [
            {
              "type": "ORGANIZATION",
              "resourceId": "3bd538c6-caa8-42ec-b60b-00bbf2e749f1"
            },
            {
              "type": "ENVIRONMENT",
              "resourceId": "env-abc123"
            },
            {
              "type": "CLOUD_CLUSTER",
              "resourceId": "lkc-12j2w5"
            }
          ]
        },
        "resource": {
          "type": "CONNECTOR",
          "resourceId": "lcc-pkdrjy"
        }
      }
    ],
    "authenticationInfo": {
      "principal": {
        "email": "someone@example.com",
        "confluentUser": {
          "resourceId": "u-4rxom7"
        }
      },
      "result": "SUCCESS"
    },
    "requestMetadata": {
      "requestId": [
        "585f36dd2933d0dda8273451476d2fd7"
      ],
      "clientAddress": [
        {
          "ip": "1.2.3.4"
        }
      ]
    },
    "request": {
      "accessType": "MODIFICATION",
      "data": {
        "name": "redshift-sink-enterprise"
      }
    },
    "result": {
      "status": "SUCCESS",
      "data": {
        "name": "redshift-sink-enterprise",
        "user_configs": {
          "aws.redshift.user": "awsuser",
          "cloud.provider": "aws",
          "input.data.format": "AVRO",
          "kafka.api.key": "****************",
          "name": "redshift-sink-enterprise",
          "aws.redshift.domain": "redshift-cluster-1.us-west-1.redshift.amazonaws.com",
          "db.timezone": "US/Pacific",
          "kafka.region": "us-west-2",
          "topics": "RedshiftSink-connect-pro-1634759921",
          "valid.kafka.api.key": "true",
          "auto.evolve": "false",
          "aws.redshift.database": "dev",
          "aws.redshift.port": "5439",
          "kafka.api.secret": "****************",
          "kafka.dedicated": "false",
          "kafka.endpoint": "SASL_SSL://pkc-12345.us-west-2.aws.confluent.cloud:9092",
          "tasks.max": "1",
          "auto.create": "true",
          "aws.redshift.password": "****************",
          "cloud.environment": "prod",
          "connector.class": "RedshiftSink",
          "internal.kafka.endpoint": "PLAINTEXT://kafka-0.kafka.pkc-12345.svc.cluster.local:9071,kafka-1.kafka.pkc-12345.svc.cluster.local:9071,kafka-2.kafka.pkc-12345.svc.cluster.local:9071"
        },
        "type": 2
      }
    },
    "resourceName": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-12j2w5/connector=lcc-pkdrjy"
  }
}

CreateOrUpdateConnector

The CreateOrUpdateConnector event is generated by a request to update a connector with the provided configuration and, if a connector with the given name doesn’t exist, a request to create a connector with the provided configuration. It sends an event message that is saved in the audit log as an event record.

To view example event messages, expand the following dropdowns:

Success

{
  "specversion": "1.0",
  "id": "16f7e1ce-683d-435c-8fec-a7dd515497cd",
  "source": "crn://confluent.cloud/",
  "type": "io.confluent.cloud/request",
  "datacontenttype": "application/json",
  "subject": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-rrrnk7/connector=lcc-gkdn7n",
  "time": "2021-10-20T21:21:15.036414311Z",
  "data": {
    "serviceName": "crn://confluent.cloud/",
    "methodName": "CreateOrUpdateConnector",
    "cloudResources": [
      {
        "scope": {
          "resources": [
            {
              "type": "ORGANIZATION",
              "resourceId": "3bd538c6-caa8-42ec-b60b-00bbf2e749f1"
            },
            {
              "type": "ENVIRONMENT",
              "resourceId": "env-abc123"
            },
            {
              "type": "CLOUD_CLUSTER",
              "resourceId": "lkc-rrrnk7"
            }
          ]
        },
        "resource": {
          "type": "CONNECTOR",
          "resourceId": "lcc-gkdn7n"
        }
      }
    ],
    "authenticationInfo": {
      "principal": {
        "email": "someone@example.com",
        "confluentUser": {
          "resourceId": "u-4rxom7"
        }
      },
      "result": "SUCCESS"
    },
    "requestMetadata": {
      "requestId": [
        "7ac2c343362fd5234352d1ca02ccd545"
      ],
      "clientAddress": [
        {
          "ip": "1.2.3.4"
        }
      ]
    },
    "request": {
      "accessType": "MODIFICATION",
      "data": {
        "name": "control-plane"
      }
    },
    "result": {
      "status": "SUCCESS",
      "data": {
        "type": 2,
        "name": "control-plane-pro",
        "user_configs": {
          "connector.class": "S3_SINK",
          "kafka.api.key": "****************",
          "s3.bucket.name": "connect-test",
          "s3.region": "us-west-2",
          "tasks.max": "1",
          "cloud.environment": "prod",
          "internal.kafka.endpoint": "PLAINTEXT://kafka-0.kafka.pkc-12345.svc.cluster.local:9071,kafka-1.kafka.pkc-12345.svc.cluster.local:9071,kafka-2.kafka.pkc-12345.svc.cluster.local:9071",
          "kafka.dedicated": "false",
          "name": "control-plane",
          "input.data.format": "JSON",
          "kafka.endpoint": "SASL_SSL://pkc-12345.us-west-2.aws.confluent.cloud:9092",
          "kafka.region": "us-west-2",
          "output.data.format": "JSON",
          "time.interval": "HOURLY",
          "topics": "connect-pro-semaphore-1634764254",
          "valid.kafka.api.key": "true",
          "aws.access.key.id": "****************",
          "aws.secret.access.key": "****************",
          "cloud.provider": "aws",
          "kafka.api.secret": "****************"
        }
      }
    },
    "resourceName": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-rrrnk7/connector=lcc-gkdn7n"
  }
}

DeleteConnector

The DeleteConnector event is generated by a request to delete a connector. It sends an event message that is saved in the audit log as an event record.

To view example event messages, expand the following dropdowns:

GetConnector

The GetConnector event is generated by a request to get the details of a connector. It sends an event message that is saved in the audit log as an event record.

To view example event messages, expand the following dropdowns:

Success

{
  "specversion": "1.0",
  "id": "f9e0e4e3-1788-4511-a2f0-64568e4791b3",
  "source": "crn://confluent.cloud/",
  "type": "io.confluent.cloud/request",
  "datacontenttype": "application/json",
  "subject": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-pgrgr5/connector=lcc-3nqrmo",
  "time": "2021-10-20T21:21:31.953972658Z",
  "data": {
    "serviceName": "crn://confluent.cloud/",
    "methodName": "GetConnector",
    "cloudResources": [
      {
        "scope": {
          "resources": [
            {
              "type": "ORGANIZATION",
              "resourceId": "3bd538c6-caa8-42ec-b60b-00bbf2e749f1"
            },
            {
              "type": "ENVIRONMENT",
              "resourceId": "env-abc123"
            },
            {
              "type": "CLOUD_CLUSTER",
              "resourceId": "lkc-pgrgr5"
            }
          ]
        },
        "resource": {
          "type": "CONNECTOR",
          "resourceId": "lcc-3nqrmo"
        }
      }
    ],
    "authenticationInfo": {
      "principal": {
        "email": "someone@example.com",
        "confluentUser": {
          "resourceId": "u-4rxom7"
        }
      },
      "result": "SUCCESS"
    },
    "requestMetadata": {
      "requestId": [
        "9ab19ef5908edc9933da05042c8737d3"
      ],
      "clientAddress": [
        {
          "ip": "1.2.3.4"
        }
      ]
    },
    "request": {
      "accessType": "READ_ONLY",
      "data": {
        "name": "s3-sink-enterprise"
      }
    },
    "result": {
      "status": "SUCCESS",
      "data": {
        "name": "s3-sink-enterprise",
        "user_configs": {
          "connector.class": "S3_SINK",
          "kafka.endpoint": "SASL_SSL://pkc-12345.us-west-2.aws.confluent.cloud:9092",
          "output.data.format": "JSON",
          "kafka.dedicated": "false",
          "kafka.region": "us-west-2",
          "tasks.max": "1",
          "time.interval": "HOURLY",
          "topics": "S3Sink-connect-pro-1634759921",
          "aws.access.key.id": "****************",
          "aws.secret.access.key": "****************",
          "cloud.provider": "aws",
          "valid.kafka.api.key": "true",
          "s3.bucket.name": "connect-sink",
          "s3.region": "us-west-2",
          "internal.kafka.endpoint": "PLAINTEXT://kafka-0.kafka.pkc-12345.svc.cluster.local:9071,kafka-1.kafka.pkc-12345.svc.cluster.local:9071,kafka-2.kafka.pkc-12345.svc.cluster.local:9071",
          "kafka.api.key": "****************",
          "kafka.api.secret": "****************",
          "cloud.environment": "prod",
          "input.data.format": "JSON",
          "name": "s3-sink-enterprise"
        },
        "type": 2
      }
    },
    "resourceName": "crn://confluent.cloud/organization=3bd538c6-caa8-42ec-b60b-00bbf2e749f1/environment=env-abc123/cloud-cluster=lkc-pgrgr5/connector=lcc-3nqrmo"
  }
}

GetConnectors

The GetConnectors event is generated by a request to get a list of connectors in the organization. It sends an event message that is saved in the audit log as an event record.

To view example event messages, expand the following dropdowns:

PauseConnector

The PauseConnector event is generated by a request to pause a connector. It sends an event message that is saved in the audit log as an event record.

To view an example event message, expand the following dropdown:

ResumeConnector

The ResumeConnector event is generated by a request to resume a connector. It sends an event message that is saved in the audit log as an event record.

To view an example event message, expand the following dropdown: