Send feedback
Class Topic (0.9.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 0.9.0 keyboard_arrow_down
public final class Topic extends GeneratedMessageV3 implements TopicOrBuilder
A Kafka topic in a given cluster.
Protobuf type google.cloud.managedkafka.v1.Topic
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
CONFIGS_FIELD_NUMBER
public static final int CONFIGS_FIELD_NUMBER
Field Value
Type Description
int
NAME_FIELD_NUMBER
public static final int NAME_FIELD_NUMBER
Field Value
Type Description
int
PARTITION_COUNT_FIELD_NUMBER
public static final int PARTITION_COUNT_FIELD_NUMBER
Field Value
Type Description
int
REPLICATION_FACTOR_FIELD_NUMBER
public static final int REPLICATION_FACTOR_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static Topic getDefaultInstance ()
Returns
Type Description
Topic
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static Topic . Builder newBuilder ()
newBuilder(Topic prototype)
public static Topic . Builder newBuilder ( Topic prototype )
Parameter
Name Description
prototypeTopic
public static Topic parseDelimitedFrom ( InputStream input )
Returns
Type Description
Topic
public static Topic parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
parseFrom(byte[] data)
public static Topic parseFrom ( byte [] data )
Parameter
Name Description
databyte []
Returns
Type Description
Topic
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static Topic parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
parseFrom(ByteString data)
public static Topic parseFrom ( ByteString data )
Returns
Type Description
Topic
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static Topic parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
public static Topic parseFrom ( CodedInputStream input )
Returns
Type Description
Topic
public static Topic parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
public static Topic parseFrom ( InputStream input )
Returns
Type Description
Topic
public static Topic parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
parseFrom(ByteBuffer data)
public static Topic parseFrom ( ByteBuffer data )
Returns
Type Description
Topic
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static Topic parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
Returns
Type Description
Topic
parser()
public static Parser<Topic> parser ()
Methods
containsConfigs(String key)
public boolean containsConfigs ( String key )
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.
map<string, string> configs = 4 [(.google.api.field_behavior) = OPTIONAL];
Parameter
Name Description
keyString
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getConfigs() (deprecated)
public Map<String , String > getConfigs ()
getConfigsCount()
public int getConfigsCount ()
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.
map<string, string> configs = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
int
getConfigsMap()
public Map<String , String > getConfigsMap ()
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.
map<string, string> configs = 4 [(.google.api.field_behavior) = OPTIONAL];
getConfigsOrDefault(String key, String defaultValue)
public String getConfigsOrDefault ( String key , String defaultValue )
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.
map<string, string> configs = 4 [(.google.api.field_behavior) = OPTIONAL];
Returns
Type Description
String
getConfigsOrThrow(String key)
public String getConfigsOrThrow ( String key )
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.
map<string, string> configs = 4 [(.google.api.field_behavior) = OPTIONAL];
Parameter
Name Description
keyString
Returns
Type Description
String
getDefaultInstanceForType()
public Topic getDefaultInstanceForType ()
Returns
Type Description
Topic
getName()
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}
string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
Returns
Type Description
String The name.
getNameBytes()
public ByteString getNameBytes ()
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}
string name = 1 [(.google.api.field_behavior) = IDENTIFIER];
Returns
Type Description
ByteString The bytes for name.
getParserForType()
public Parser<Topic> getParserForType ()
Overrides
getPartitionCount()
public int getPartitionCount ()
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.
int32 partition_count = 2 [(.google.api.field_behavior) = REQUIRED];
Returns
Type Description
int The partitionCount.
getReplicationFactor()
public int getReplicationFactor ()
Required. Immutable. The number of replicas of each partition. A
replication factor of 3 is recommended for high availability.
int32 replication_factor = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
Returns
Type Description
int The replicationFactor.
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
Overrides
hashCode()
Returns
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
internalGetMapFieldReflection(int number)
protected MapFieldReflectionAccessor internalGetMapFieldReflection ( int number )
Parameter
Name Description
numberint
Returns
Type Description
com.google.protobuf.MapFieldReflectionAccessor
Overrides
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public Topic . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected Topic . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public Topic . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-01-28 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-01-28 UTC."],[],[]]
