public sealed class Topic : IMessage<Topic>, IEquatable<Topic>, IDeepCloneable<Topic>, IBufferMessage, IMessage
Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class Topic.
A Kafka topic in a given cluster.
Namespace
Google.Cloud.ManagedKafka.V1Assembly
Google.Cloud.ManagedKafka.V1.dll
Constructors
Topic()
public Topic()
Topic(Topic)
public Topic(Topic other)
Parameter | |
---|---|
Name | Description |
other |
Topic |
Properties
Configs
public MapField<string, string> Configs { get; }
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
.
Property Value | |
---|---|
Type | Description |
MapFieldstringstring |
Name
public string Name { get; set; }
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}
Property Value | |
---|---|
Type | Description |
string |
PartitionCount
public int PartitionCount { get; set; }
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.
Property Value | |
---|---|
Type | Description |
int |
ReplicationFactor
public int ReplicationFactor { get; set; }
Required. Immutable. The number of replicas of each partition. A replication factor of 3 is recommended for high availability.
Property Value | |
---|---|
Type | Description |
int |
TopicName
public TopicName TopicName { get; set; }
Property Value | |
---|---|
Type | Description |
TopicName |