DBZ-7099 Refactor to named constant
This commit is contained in:
parent
60939c8965
commit
0f86db81b3
@ -37,13 +37,13 @@ public boolean performCommit(long numberOfMessagesSinceLastCommit, Duration time
|
|||||||
*/
|
*/
|
||||||
class PeriodicCommitOffsetPolicy implements OffsetCommitPolicy {
|
class PeriodicCommitOffsetPolicy implements OffsetCommitPolicy {
|
||||||
|
|
||||||
|
private static final Duration DEFAULT_COMMIT_OFFSET_INTERVAL = Duration.ofMinutes(1);
|
||||||
private final Duration minimumTime;
|
private final Duration minimumTime;
|
||||||
|
|
||||||
public PeriodicCommitOffsetPolicy(Properties config) {
|
public PeriodicCommitOffsetPolicy(Properties config) {
|
||||||
final long interval = config.containsKey(DebeziumEngine.OFFSET_FLUSH_INTERVAL_MS_PROP)
|
minimumTime = config.containsKey(DebeziumEngine.OFFSET_FLUSH_INTERVAL_MS_PROP)
|
||||||
? Long.valueOf(config.getProperty(DebeziumEngine.OFFSET_FLUSH_INTERVAL_MS_PROP))
|
? Duration.ofMillis(Long.valueOf(config.getProperty(DebeziumEngine.OFFSET_FLUSH_INTERVAL_MS_PROP)))
|
||||||
: 60000L;
|
: DEFAULT_COMMIT_OFFSET_INTERVAL;
|
||||||
minimumTime = Duration.ofMillis(interval);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
Reference in New Issue
Block a user