Query
query KafkaInferSchema($input: KafkaInferSchemaInput!) {
kafkaInferSchema(input: $input)
}Variables
{
"input": {
"credentialId": "value",
"topic": "string"
}
}Response
{
"data": {
"kafkaInferSchema": "value"
}
}Queries
kafkaInferSchema
Infer schema from a Kafka topic. Requires SOURCES_READ permissions. Has a timeout of 600 seconds.
QUERY
kafkaInferSchema(input: KafkaInferSchemaInput!): JsonTypeDefinition!Arguments
input
required
Returns
JsonTypeDefinition!
Query
query KafkaInferSchema($input: KafkaInferSchemaInput!) {
kafkaInferSchema(input: $input)
}Variables
{
"input": {
"credentialId": "value",
"topic": "string"
}
}Response
{
"data": {
"kafkaInferSchema": "value"
}
}