@Internal public class OffsetCommitModes extends Object
OffsetCommitMode
.Constructor and Description |
---|
OffsetCommitModes() |
Modifier and Type | Method and Description |
---|---|
static OffsetCommitMode |
fromConfiguration(boolean enableAutoCommit,
boolean enableCommitOnCheckpoint,
boolean enableCheckpointing)
Determine the offset commit mode using several configuration values.
|
public static OffsetCommitMode fromConfiguration(boolean enableAutoCommit, boolean enableCommitOnCheckpoint, boolean enableCheckpointing)
enableAutoCommit
- whether or not auto committing is enabled in the provided Kafka
properties.enableCommitOnCheckpoint
- whether or not committing on checkpoints is enabled.enableCheckpointing
- whether or not checkpoint is enabled for the consumer.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.