Package com.atlan.model.structs

Class KafkaTopicConsumption

java.lang.Object

com.atlan.model.core.AtlanObject

com.atlan.model.structs.AtlanStruct

com.atlan.model.structs.KafkaTopicConsumption

All Implemented Interfaces:

Serializable

@Generated("com.atlan.generators.ModelGeneratorV2")
public class KafkaTopicConsumption
extends AtlanStruct

Detailed information about the consumption of a Kafka topic.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaTopicConsumption.KafkaTopicConsumptionBuilder<C extends KafkaTopicConsumption,B extends KafkaTopicConsumption.KafkaTopicConsumptionBuilder<C,B>>

Nested classes/interfaces inherited from class com.atlan.model.structs.AtlanStruct

AtlanStruct.AtlanStructBuilder<C extends AtlanStruct,B extends AtlanStruct.AtlanStructBuilder<C,B>>

Nested classes/interfaces inherited from class com.atlan.model.core.AtlanObject

AtlanObject.AtlanObjectBuilder<C extends AtlanObject,B extends AtlanObject.AtlanObjectBuilder<C,B>>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_NAME

Fields inherited from class com.atlan.model.core.AtlanObject

rawJsonObject

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	KafkaTopicConsumption(KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?> b)

Method Summary

Modifier and Type	Method	Description
static KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?>	builder()
protected boolean	canEqual(Object other)
boolean	equals(Object o)
Long	getTopicCurrentOffset()	Current offset of the Kafka topic.
Long	getTopicLag()	Lag of the Kafka topic.
String	getTopicName()	Name of the Kafka topic.
String	getTopicPartition()	Partition of the Kafka topic.
String	getTypeName()	Fixed typeName for KafkaTopicConsumption.
int	hashCode()
static KafkaTopicConsumption	of(String topicName, String topicPartition, Long topicLag, Long topicCurrentOffset)	Quickly create a new KafkaTopicConsumption.
KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?>	toBuilder()
String	toString()

Methods inherited from class com.atlan.model.core.AtlanObject

getRawJsonObject, setRawJsonObject, toJson

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

TYPE_NAME

public static final String TYPE_NAME

See Also:

• Constant Field Values

Constructor Details

KafkaTopicConsumption

protected KafkaTopicConsumption(KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?> b)

Method Details

of

public static KafkaTopicConsumption of(String topicName,
 String topicPartition,
 Long topicLag,
 Long topicCurrentOffset)

Quickly create a new KafkaTopicConsumption.

Parameters:

topicName - Name of the Kafka topic.

topicPartition - Partition of the Kafka topic.

topicLag - Lag of the Kafka topic.

topicCurrentOffset - Current offset of the Kafka topic.

Returns:

a KafkaTopicConsumption with the provided information

builder

public static KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?> builder()

toBuilder

public KafkaTopicConsumption.KafkaTopicConsumptionBuilder<?,?> toBuilder()

getTopicName

public String getTopicName()

Name of the Kafka topic.

getTopicPartition

public String getTopicPartition()

Partition of the Kafka topic.

getTopicLag

public Long getTopicLag()

Lag of the Kafka topic.

getTopicCurrentOffset

public Long getTopicCurrentOffset()

Current offset of the Kafka topic.

equals

public boolean equals(Object o)

Overrides:

equals in class AtlanStruct

canEqual

protected boolean canEqual(Object other)

Overrides:

canEqual in class AtlanStruct

hashCode

public int hashCode()

Overrides:

hashCode in class AtlanStruct

toString

public String toString()

Description copied from class: AtlanObject

Overrides:

toString in class AtlanObject

getTypeName

public String getTypeName()

Fixed typeName for KafkaTopicConsumption.

Overrides:

getTypeName in class AtlanStruct