Skip to content

KAFKA-19822: Remove all unused static classes in Field #20799

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 4 commits into from
Nov 5, 2025
+10 −462
Merged

KAFKA-19822: Remove all unused static classes in Field #20799

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
cd59cff
KAFKA-19822: Remove all unused static classes in Field
DL1231 Oct 31, 2025
7534e2d
fix comment
DL1231 Nov 1, 2025
293f233
Merge remote-tracking branch 'origin/trunk' into KAFKA-19822
DL1231 Nov 1, 2025
5a5bfee
fix comment
DL1231 Nov 1, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
134 changes: 0 additions & 134 deletions clients/src/main/java/org/apache/kafka/common/protocol/types/Field.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -46,115 +46,6 @@ public Field(String name, Type type) {
this(name, type, null, false, null);
}

public static class Int8 extends Field {
public Int8(String name, String docString) {
super(name, Type.INT8, docString, false, null);
}
public Int8(String name, String docString, byte defaultValue) {
super(name, Type.INT8, docString, true, defaultValue);
}
}

public static class Int32 extends Field {
public Int32(String name, String docString) {
super(name, Type.INT32, docString, false, null);
}

public Int32(String name, String docString, int defaultValue) {
super(name, Type.INT32, docString, true, defaultValue);
}
}

public static class Int64 extends Field {
public Int64(String name, String docString) {
super(name, Type.INT64, docString, false, null);
}

public Int64(String name, String docString, long defaultValue) {
super(name, Type.INT64, docString, true, defaultValue);
}
}

public static class UUID extends Field {
public UUID(String name, String docString) {
super(name, Type.UUID, docString, false, null);
}

public UUID(String name, String docString, UUID defaultValue) {
super(name, Type.UUID, docString, true, defaultValue);
}
}

public static class Int16 extends Field {
public Int16(String name, String docString) {
super(name, Type.INT16, docString, false, null);
}
}

public static class Uint16 extends Field {
public Uint16(String name, String docString) {
super(name, Type.UINT16, docString, false, null);
}
}

public static class Uint32 extends Field {
public Uint32(String name, String docString) {
super(name, Type.UNSIGNED_INT32, docString, false, null);
}
}

public static class Float64 extends Field {
public Float64(String name, String docString) {
super(name, Type.FLOAT64, docString, false, null);
}

public Float64(String name, String docString, double defaultValue) {
super(name, Type.FLOAT64, docString, true, defaultValue);
}
}

public static class Str extends Field {
public Str(String name, String docString) {
super(name, Type.STRING, docString, false, null);
}
}

public static class CompactStr extends Field {
public CompactStr(String name, String docString) {
super(name, Type.COMPACT_STRING, docString, false, null);
}
}

public static class NullableStr extends Field {
public NullableStr(String name, String docString) {
super(name, Type.NULLABLE_STRING, docString, false, null);
}
}

public static class CompactNullableStr extends Field {
public CompactNullableStr(String name, String docString) {
super(name, Type.COMPACT_NULLABLE_STRING, docString, false, null);
}
}

public static class Bool extends Field {
public Bool(String name, String docString) {
super(name, Type.BOOLEAN, docString, false, null);
}
}

public static class Array extends Field {
public Array(String name, Type elementType, String docString) {
super(name, new ArrayOf(elementType), docString, false, null);
}
}

public static class CompactArray extends Field {
public CompactArray(String name, Type elementType, String docString) {
super(name, new CompactArrayOf(elementType), docString, false, null);
}
}

public static class TaggedFieldsSection extends Field {
private static final String NAME = "_tagged_fields";
private static final String DOC_STRING = "The tagged fields";
Expand All @@ -174,29 +65,4 @@ public TaggedFieldsSection(Type type) {
super(NAME, type, DOC_STRING, false, null);
}
}

public static class ComplexArray {
public final String name;
public final String docString;

public ComplexArray(String name, String docString) {
this.name = name;
this.docString = docString;
}

public Field withFields(Field... fields) {
Schema elementType = new Schema(fields);
return new Field(name, new ArrayOf(elementType), docString, false, null);
}

public Field nullableWithFields(Field... fields) {
Schema elementType = new Schema(fields);
return new Field(name, ArrayOf.nullable(elementType), docString, false, null);
}

public Field withFields(String docStringOverride, Field... fields) {
Schema elementType = new Schema(fields);
return new Field(name, new ArrayOf(elementType), docStringOverride, false, null);
}
}
}
Loading