Topic

import type { Topic } from "https://googleapis.deno.dev/v1/managedkafka:v1.ts";

A Kafka topic in a given cluster.

interface Topic {

configs?: {

[key: string]: string;

};

name?: string;

partitionCount?: number;

replicationFactor?: number;

}

§Properties

configs?: {

[key: string]: string;

}

[src]

Optional. Configurations for the topic that are overridden from the cluster defaults. The key of the map is a Kafka topic property name, for example: cleanup.policy, compression.type.

name?: string

[src]

Identifier. The name of the topic. The topic segment is used when connecting directly to the cluster. Structured like: projects/{project}/locations/{location}/clusters/{cluster}/topics/{topic}

partitionCount?: number

[src]

Required. The number of partitions this topic has. The partition count can only be increased, not decreased. Please note that if partitions are increased for a topic that has a key, the partitioning logic or the ordering of the messages will be affected.

replicationFactor?: number

[src]

Required. Immutable. The number of replicas of each partition. A replication factor of 3 is recommended for high availability.