CreateKafkaTopic#

Description#

Request to create a Kafka topic.

Request Parameters#

  • name — The name of the Kafka topic.

  • Type: String

  • Required: Yes

  • parameters — The parameters of the Kafka topic.

    • Type: Dict

    • Required: Yes

  • serviceId — The PaaS service ID.

    • Type: String

    • Required: Yes

Response Elements#

  • kafkaTopic — The created Kafka topic.

Examples#

Managing PaaS services in K2 Cloud via API requires a customized version of the boto3 library:

import boto3

session = boto3.Session(
    aws_access_key_id="<AWS_ACCESS_KEY_ID>",
    aws_secret_access_key="<AWS_SECRET_ACCESS_KEY>",
    region_name="",
)

paas_client = session.client(
    'paas',
    endpoint_url='https://paas.k2.cloud/',
)

topic = paas_client.create_kafka_topic(
     serviceId='fm-cluster-1ACD3963',
     name="my-topic",
     parameters={
         "partitions": 3,
         "replicationFactor": 3
     }
)

Or c2-paas utility from K2 Cloud API Client software suite:

c2-paas CreateKafkaTopic serviceId fm-cluster-1ACD3963 name my-topic parameters.partitions 3 parameters.replicationFactor 3