Class KafkaChannelConfiguration.InitialOffsetTypes
- java.lang.Object
-
- org.mases.datadistributionmanager.configuration.KafkaChannelConfiguration.InitialOffsetTypes
-
- Enclosing class:
- KafkaChannelConfiguration
public static class KafkaChannelConfiguration.InitialOffsetTypes extends java.lang.Object
Specific values to use withinCommonConfiguration.setInitialOffset(Long)
when channel is based on Kafka
-
-
Field Summary
Fields Modifier and Type Field Description static long
Beginning
Start consuming from beginning of kafka partition queue: oldest messagestatic long
End
Start consuming from end of kafka partition queue: next messagestatic long
Stored
Start consuming from offset retrieved from offset store
-
Constructor Summary
Constructors Constructor Description InitialOffsetTypes()
-
-
-
Field Detail
-
Beginning
public static long Beginning
Start consuming from beginning of kafka partition queue: oldest message
-
End
public static long End
Start consuming from end of kafka partition queue: next message
-
Stored
public static long Stored
Start consuming from offset retrieved from offset store
-
-