Skip to content

Commit 5a42d31

Browse files
committed
fix: Use CaseTransform logging and simplify helper
1 parent de2afac commit 5a42d31

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

src/main/java/io/aiven/kafka/connect/transforms/CaseTransform.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
*/
4141
public abstract class CaseTransform<R extends ConnectRecord<R>> implements Transformation<R> {
4242

43-
private static final Logger LOGGER = LoggerFactory.getLogger(ConcatFields.class);
43+
private static final Logger LOGGER = LoggerFactory.getLogger(CaseTransform.class);
4444

4545
/**
4646
* The configuration for case transform.
@@ -60,13 +60,12 @@ public abstract class CaseTransform<R extends ConnectRecord<R>> implements Trans
6060

6161
/**
6262
* Apply the case transformation to given new struct from the original struct field.
63-
* @param struct Original struct
6463
* @param newStruct New struct
6564
* @param fieldName The field name to case transform
6665
*/
67-
private void applyStruct(final Struct struct, final Struct newStruct, final String fieldName) {
66+
private void applyStruct(final Struct newStruct, final String fieldName) {
6867
try {
69-
final Object value = struct.get(fieldName);
68+
final Object value = newStruct.get(fieldName);
7069
if (value == null) {
7170
newStruct.put(fieldName, null);
7271
return;
@@ -108,7 +107,7 @@ public R apply(final R record) {
108107
newStruct.put(field.name(), struct.get(field));
109108
});
110109
config.fieldNames().forEach(field -> {
111-
applyStruct(struct, newStruct, field);
110+
applyStruct(newStruct, field);
112111
});
113112
newRecord = createNewRecord(record, struct.schema(), newStruct);
114113
} else if (schemaAndValue.value() instanceof Map) {

0 commit comments

Comments
 (0)