-
Notifications
You must be signed in to change notification settings - Fork 97
/
AutoOffsetReset.scala
49 lines (41 loc) · 1.39 KB
/
AutoOffsetReset.scala
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
/*
* Copyright 2018-2022 OVO Energy Limited
*
* SPDX-License-Identifier: Apache-2.0
*/
package fs2.kafka
/**
* The available options for [[ConsumerSettings#withAutoOffsetReset]].<br>
* <br>
* Available options include:<br>
* - [[AutoOffsetReset#Earliest]] to reset to the earliest offsets,<br>
* - [[AutoOffsetReset#Latest]] to reset to the latest offsets,<br>
* - [[AutoOffsetReset#None]] to fail if no offsets are available.
*/
sealed abstract class AutoOffsetReset
object AutoOffsetReset {
private[kafka] case object EarliestOffsetReset extends AutoOffsetReset {
override def toString: String = "Earliest"
}
private[kafka] case object LatestOffsetReset extends AutoOffsetReset {
override def toString: String = "Latest"
}
private[kafka] case object NoneOffsetReset extends AutoOffsetReset {
override def toString: String = "None"
}
/**
* Option to reset to the earliest available offsets if no
* initial or current offsets exist for the consumer group.
*/
val Earliest: AutoOffsetReset = EarliestOffsetReset
/**
* Option to reset to the latest available offsets if no
* initial or current offsets exist for the consumer group.
*/
val Latest: AutoOffsetReset = LatestOffsetReset
/**
* Option to fail the consumer if there are no offsets
* available for the consumer group.
*/
val None: AutoOffsetReset = NoneOffsetReset
}