Managed Service for Apache Kafka® Audit Trails Events: ResumeConnector
- Event JSON schema
- Field description
- IamAuthentication
- IamTokenInfo
- Authorization
- ResourceMetadata
- Resource
- RequestMetadata
- Status
- ConnectorEventDetails
- Connector
- ConnectorConfigMirrorMaker
- ClusterConnection
- ExternalClusterConnection
- ConnectorConfigS3Sink
- S3Connection
- ExternalS3Storage
- ConnectorConfigIcebergSink
- MetastoreConnection
- IcebergS3Connection
- ExternalIcebergS3Storage
- StaticTables
- DynamicTables
- IcebergTablesConfig
- IcebergControl
Event JSON schema
{
"eventId": "string",
"eventSource": "string",
"eventType": "string",
"eventTime": "string",
"authentication": {
"authenticated": "boolean",
// Includes only one of the fields `subjectType`
"subjectType": "string",
// end of the list of possible fields
// Includes only one of the fields `subjectId`
"subjectId": "string",
// end of the list of possible fields
// Includes only one of the fields `subjectName`
"subjectName": "string",
// end of the list of possible fields
// Includes only one of the fields `federationId`
"federationId": "string",
// end of the list of possible fields
// Includes only one of the fields `federationName`
"federationName": "string",
// end of the list of possible fields
// Includes only one of the fields `federationType`
"federationType": "string",
// end of the list of possible fields
"tokenInfo": {
"maskedIamToken": "string",
// Includes only one of the fields `iamTokenId`
"iamTokenId": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorId`
"impersonatorId": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorType`
"impersonatorType": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorName`
"impersonatorName": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorFederationId`
"impersonatorFederationId": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorFederationName`
"impersonatorFederationName": "string",
// end of the list of possible fields
// Includes only one of the fields `impersonatorFederationType`
"impersonatorFederationType": "string"
// end of the list of possible fields
}
},
"authorization": {
"authorized": "boolean"
},
"resourceMetadata": {
"path": [
{
"resourceType": "string",
"resourceId": "string",
// Includes only one of the fields `resourceName`
"resourceName": "string"
// end of the list of possible fields
}
]
},
"requestMetadata": {
"remoteAddress": "string",
"userAgent": "string",
"requestId": "string",
// Includes only one of the fields `remotePort`
"remotePort": "string"
// end of the list of possible fields
},
"eventStatus": "string",
"error": {
"code": "integer",
"message": "string",
"details": [
"object"
]
},
"details": {
"clusterId": "string",
"connectorName": "string",
"clusterName": "string",
"connector": {
"name": "string",
"tasksMax": "string",
"properties": "object",
"health": "string",
"status": "string",
"clusterId": "string",
// Includes only one of the fields `connectorConfigMirrormaker`, `connectorConfigS3Sink`, `connectorConfigIcebergSink`
"connectorConfigMirrormaker": {
"sourceCluster": {
"alias": "string",
// Includes only one of the fields `thisCluster`, `externalCluster`
"thisCluster": "object",
"externalCluster": {
"bootstrapServers": "string",
"saslUsername": "string",
"saslMechanism": "string",
"securityProtocol": "string"
}
// end of the list of possible fields
},
"targetCluster": {
"alias": "string",
// Includes only one of the fields `thisCluster`, `externalCluster`
"thisCluster": "object",
"externalCluster": {
"bootstrapServers": "string",
"saslUsername": "string",
"saslMechanism": "string",
"securityProtocol": "string"
}
// end of the list of possible fields
},
"topics": "string",
"replicationFactor": "string"
},
"connectorConfigS3Sink": {
"topics": "string",
"fileCompressionType": "string",
"fileMaxRecords": "string",
"s3Connection": {
"bucketName": "string",
// Includes only one of the fields `externalS3`
"externalS3": {
"accessKeyId": "string",
"endpoint": "string",
"region": "string"
}
// end of the list of possible fields
}
},
"connectorConfigIcebergSink": {
// Includes only one of the fields `topics`, `topicsRegex`
"topics": "string",
"topicsRegex": "string",
// end of the list of possible fields
"controlTopic": "string",
"metastoreConnection": {
"catalogUri": "string",
"warehouse": "string"
},
"s3Connection": {
// Includes only one of the fields `externalS3`
"externalS3": {
"accessKeyId": "string",
"endpoint": "string",
"region": "string"
}
// end of the list of possible fields
},
// Includes only one of the fields `staticTables`, `dynamicTables`
"staticTables": {
"tables": "string"
},
"dynamicTables": {
"routeField": "string"
},
// end of the list of possible fields
"tablesConfig": {
"defaultCommitBranch": "string",
"defaultIdColumns": "string",
"defaultPartitionBy": "string",
"evolveSchemaEnabled": "boolean",
"schemaForceOptional": "boolean",
"schemaCaseInsensitive": "boolean"
},
"controlConfig": {
"groupIdPrefix": "string",
"commitIntervalMs": "string",
"commitTimeoutMs": "string",
"commitThreads": "string",
"transactionalPrefix": "string"
}
}
// end of the list of possible fields
}
},
"requestParameters": "object",
"response": "object"
}
Field description
|
Field |
Description |
|
eventId |
string |
|
eventSource |
string |
|
eventType |
string |
|
eventTime |
string (date-time) String in RFC3339 To work with values in this field, use the APIs described in the |
|
authentication |
|
|
authorization |
|
|
resourceMetadata |
|
|
requestMetadata |
|
|
eventStatus |
enum (EventStatus)
|
|
error |
The error result of the operation in case of failure or cancellation. |
|
details |
|
|
requestParameters |
object |
|
response |
object |
IamAuthentication
|
Field |
Description |
|
authenticated |
boolean |
|
subjectType |
enum (IamSubjectType) Includes only one of the fields
|
|
subjectId |
string Includes only one of the fields |
|
subjectName |
string Includes only one of the fields |
|
federationId |
string Includes only one of the fields |
|
federationName |
string Includes only one of the fields |
|
federationType |
enum (FederationType) Includes only one of the fields
|
|
tokenInfo |
IamTokenInfo
|
Field |
Description |
|
maskedIamToken |
string |
|
iamTokenId |
string Includes only one of the fields |
|
impersonatorId |
string Includes only one of the fields |
|
impersonatorType |
enum (IamSubjectType) Includes only one of the fields
|
|
impersonatorName |
string Includes only one of the fields |
|
impersonatorFederationId |
string Includes only one of the fields |
|
impersonatorFederationName |
string Includes only one of the fields |
|
impersonatorFederationType |
enum (FederationType) Includes only one of the fields
|
Authorization
|
Field |
Description |
|
authorized |
boolean |
ResourceMetadata
|
Field |
Description |
|
path[] |
Resource
|
Field |
Description |
|
resourceType |
string |
|
resourceId |
string |
|
resourceName |
string Includes only one of the fields |
RequestMetadata
|
Field |
Description |
|
remoteAddress |
string |
|
userAgent |
string |
|
requestId |
string |
|
remotePort |
string (int64) Includes only one of the fields |
Status
The error result of the operation in case of failure or cancellation.
|
Field |
Description |
|
code |
integer (int32) Error code. An enum value of google.rpc.Code |
|
message |
string An error message. |
|
details[] |
object A list of messages that carry the error details. |
ConnectorEventDetails
|
Field |
Description |
|
clusterId |
string The maximum string length in characters is 50. |
|
connectorName |
string The maximum string length in characters is 256. |
|
clusterName |
string The maximum string length in characters is 63. |
|
connector |
Connector
|
Field |
Description |
|
name |
string |
|
tasksMax |
string (int64) |
|
properties |
object (map<string, string>) |
|
health |
enum (Health)
|
|
status |
enum (Status)
|
|
clusterId |
string |
|
connectorConfigMirrormaker |
Includes only one of the fields |
|
connectorConfigS3Sink |
Includes only one of the fields |
|
connectorConfigIcebergSink |
Includes only one of the fields |
ConnectorConfigMirrorMaker
|
Field |
Description |
|
sourceCluster |
|
|
targetCluster |
|
|
topics |
string |
|
replicationFactor |
string (int64) |
ClusterConnection
|
Field |
Description |
|
alias |
string |
|
thisCluster |
object Includes only one of the fields |
|
externalCluster |
Includes only one of the fields |
ExternalClusterConnection
|
Field |
Description |
|
bootstrapServers |
string |
|
saslUsername |
string |
|
saslMechanism |
string |
|
securityProtocol |
string |
ConnectorConfigS3Sink
|
Field |
Description |
|
topics |
string |
|
fileCompressionType |
string |
|
fileMaxRecords |
string (int64) |
|
s3Connection |
S3Connection
|
Field |
Description |
|
bucketName |
string |
|
externalS3 |
Includes only one of the fields |
ExternalS3Storage
|
Field |
Description |
|
accessKeyId |
string |
|
endpoint |
string |
|
region |
string |
ConnectorConfigIcebergSink
|
Field |
Description |
|
topics |
string Includes only one of the fields |
|
topicsRegex |
string Includes only one of the fields |
|
controlTopic |
string |
|
metastoreConnection |
|
|
s3Connection |
|
|
staticTables |
Includes only one of the fields |
|
dynamicTables |
Includes only one of the fields |
|
tablesConfig |
|
|
controlConfig |
MetastoreConnection
|
Field |
Description |
|
catalogUri |
string |
|
warehouse |
string |
IcebergS3Connection
|
Field |
Description |
|
externalS3 |
Includes only one of the fields |
ExternalIcebergS3Storage
|
Field |
Description |
|
accessKeyId |
string |
|
endpoint |
string |
|
region |
string |
StaticTables
|
Field |
Description |
|
tables |
string |
DynamicTables
|
Field |
Description |
|
routeField |
string |
IcebergTablesConfig
|
Field |
Description |
|
defaultCommitBranch |
string |
|
defaultIdColumns |
string |
|
defaultPartitionBy |
string |
|
evolveSchemaEnabled |
boolean |
|
schemaForceOptional |
boolean |
|
schemaCaseInsensitive |
boolean |
IcebergControl
|
Field |
Description |
|
groupIdPrefix |
string |
|
commitIntervalMs |
string (int64) |
|
commitTimeoutMs |
string (int64) |
|
commitThreads |
string (int64) |
|
transactionalPrefix |
string |