root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: DirectoryId.MIGRATING should be all zeros (#14858) 

DirectoryId.MIGRATING should be all zeros. All zeros is the default Uuid value in KPRC, and
MIGRATING is the default directory ID value.

Reviewers: Ron Dagostino <rdagostino@confluent.io>
This commit is contained in:
Colin Patrick McCabe 2023-11-29 13:12:33 -08:00 committed by GitHub
parent 9f896ed6c9
commit bd18551b32
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
server-common/src/main/java/org/apache/kafka/common/DirectoryId.java
View File

@ -23,25 +23,24 @@ import java.util.List;
import java.util.Map;
public class DirectoryId {
/**
* A Uuid that is used to identify new or unknown dir assignments.
*/
public static final Uuid UNASSIGNED = new Uuid(0L, 0L);
/**
* A Uuid that is used to represent unspecified offline dirs.
*/
public static final Uuid LOST = new Uuid(0L, 1L);
/**
* A Uuid that is used to represent and unspecified log directory,
* A Uuid that is used to represent an unspecified log directory,
* that is expected to have been previously selected to host an
* associated replica. This contrasts with {@code UNASSIGNED_DIR},
* which is associated with (typically new) replicas that may not
* yet have been placed in any log directory.
*/
public static final Uuid MIGRATING = new Uuid(0L, 2L);
public static final Uuid MIGRATING = new Uuid(0L, 0L);
/**
* A Uuid that is used to represent directories that are pending an assignment.
*/
public static final Uuid UNASSIGNED = new Uuid(0L, 1L);
/**
* A Uuid that is used to represent unspecified offline dirs.
*/
public static final Uuid LOST = new Uuid(0L, 2L);
/**
* Static factory to generate a directory ID.