public Kafka startFromSpecificOffsets ( Map < Integer , Long > specificOffsets ) { this . startupMode = StartupMode . SPECIFIC_OFFSETS ; this . specificOffsets = Preconditions . checkNotNull ( specificOffsets ) ; return this ; }
Configures to start reading partitions from specific offsets set independently for each partition . Resets previously set offsets .