connection_tables
Create a new connection table
connection_tables
Create a new connection table
POST
/
v1
/
connection_tables
object
*
config
string
*
config
Required
string
connectionProfileId
string
connectionProfileId
string
connector
string
*
connector
Required
string
name
string
*
name
Required
string
schema
object
schema
object
badData
Option 1 · object
badData
object
fail
object
*
fail
Required
object
definition
Option 1 · object
definition
object
json_schema
string
*
json_schema
Required
string
fields
array
*
fields
Required
array
format
Option 1 · object
format
object
json
object
*
json
Required
object
confluentSchemaRegistry
boolean
confluentSchemaRegistry
boolean
debezium
boolean
debezium
boolean
includeSchema
boolean
includeSchema
boolean
schemaId
integer
schemaId
integer
timestampFormat
enum<string>
timestampFormat
enum<string>
unstructured
boolean
unstructured
boolean
framing
object
framing
object
method
object
*
method
Required
object
newline
object
*
newline
Required
object
maxLineLength
integer
maxLineLength
integer
inferred
boolean
inferred
boolean
structName
string
structName
string
Body
application/json
config
any
requiredconnectionProfileId
string | null
connector
string
requiredname
string
requiredschema
object
schema.badData
object
schema.badData.fail
object
requiredschema.definition
object
schema.definition.json_schema
string
requiredschema.fields
object[]
requiredschema.fields.fieldName
string
requiredschema.fields.fieldType
object
requiredschema.fields.fieldType.sqlName
string | null
schema.fields.fieldType.type
object
requiredschema.fields.fieldType.type.primitive
enum<string>
requiredAvailable options:
Int32, Int64, UInt32, UInt64, F32, F64, Bool, String, Bytes, UnixMillis, UnixMicros, UnixNanos, DateTime, Json schema.fields.nullable
boolean
requiredschema.format
object
schema.format.json
object
requiredschema.format.json.confluentSchemaRegistry
boolean
schema.format.json.debezium
boolean
schema.format.json.includeSchema
boolean
schema.format.json.schemaId
integer | null
schema.format.json.timestampFormat
enum<string>
Available options:
rfc3339, unix_millis schema.format.json.unstructured
boolean
schema.framing
object
schema.framing.method
object
requiredschema.framing.method.newline
object
requiredschema.framing.method.newline.maxLineLength
integer | null
schema.inferred
boolean | null
schema.structName
string | null
Response
200 - application/json
config
any
requiredconnectionProfile
object
connectionProfile.config
any
requiredconnectionProfile.connector
string
requiredconnectionProfile.description
string
requiredconnectionProfile.id
string
requiredconnectionProfile.name
string
requiredconnector
string
requiredconsumers
integer
requiredcreatedAt
integer
requiredid
string
requiredname
string
requiredschema
object
requiredschema.badData
object
schema.badData.fail
object
requiredschema.definition
object
schema.definition.json_schema
string
requiredschema.fields
object[]
requiredschema.fields.fieldName
string
requiredschema.fields.fieldType
object
requiredschema.fields.fieldType.sqlName
string | null
schema.fields.fieldType.type
object
requiredschema.fields.fieldType.type.primitive
enum<string>
requiredAvailable options:
Int32, Int64, UInt32, UInt64, F32, F64, Bool, String, Bytes, UnixMillis, UnixMicros, UnixNanos, DateTime, Json schema.fields.nullable
boolean
requiredschema.format
object
schema.format.json
object
requiredschema.format.json.confluentSchemaRegistry
boolean
schema.format.json.debezium
boolean
schema.format.json.includeSchema
boolean
schema.format.json.schemaId
integer | null
schema.format.json.timestampFormat
enum<string>
Available options:
rfc3339, unix_millis schema.format.json.unstructured
boolean
schema.framing
object
schema.framing.method
object
requiredschema.framing.method.newline
object
requiredschema.framing.method.newline.maxLineLength
integer | null
schema.inferred
boolean | null
schema.structName
string | null
tableType
enum<string>
requiredAvailable options:
source, sink