Class SubscriptionState.LogTruncation
java.lang.Object
org.apache.kafka.clients.consumer.internals.SubscriptionState.LogTruncation
- Enclosing class:
SubscriptionState
-
Field Summary
FieldsModifier and TypeFieldDescriptionfinal Optional<OffsetAndMetadata> final org.apache.kafka.common.TopicPartition -
Constructor Summary
ConstructorsConstructorDescriptionLogTruncation(org.apache.kafka.common.TopicPartition topicPartition, SubscriptionState.FetchPosition fetchPosition, Optional<OffsetAndMetadata> divergentOffsetOpt) -
Method Summary
-
Field Details
-
topicPartition
public final org.apache.kafka.common.TopicPartition topicPartition -
fetchPosition
-
divergentOffsetOpt
-
-
Constructor Details
-
LogTruncation
public LogTruncation(org.apache.kafka.common.TopicPartition topicPartition, SubscriptionState.FetchPosition fetchPosition, Optional<OffsetAndMetadata> divergentOffsetOpt)
-
-
Method Details