public static OffsetCommitMode fromConfiguration ( boolean enableAutoCommit , boolean enableCommitOnCheckpoint , boolean enableCheckpointing ) { if ( enableCheckpointing ) { // if checkpointing is enabled, the mode depends only on whether committing on checkpoints is enabled return ( enableCommitOnCheckpoint ) ? OffsetCommitMode . ON_CHECKPOINTS : OffsetCommitMode . DISABLED ; } else { // else, the mode depends only on whether auto committing is enabled in the provided Kafka properties return ( enableAutoCommit ) ? OffsetCommitMode . KAFKA_PERIODIC : OffsetCommitMode . DISABLED ; } }
Determine the offset commit mode using several configuration values .