Skip to content

Commit c4998d5

Browse files
committed
fix(api): fix wrong argurments passed to TypedStruct
1 parent 41fca73 commit c4998d5

File tree

1 file changed

+2
-2
lines changed
  • connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/data

1 file changed

+2
-2
lines changed

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/data/TypedStruct.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ private TypedStruct(final StructSchema schema) {
8282
*/
8383
@Override
8484
public TypedStruct put(final String field, final Short value) {
85-
return put(field, Schema.int16(), field);
85+
return put(field, Schema.int16(), value);
8686
}
8787

8888
/**
@@ -98,7 +98,7 @@ public TypedStruct put(final String field, final String value) {
9898
*/
9999
@Override
100100
public TypedStruct put(final String field, final Integer value) {
101-
return put(field, Schema.int32(), field);
101+
return put(field, Schema.int32(), value);
102102
}
103103

104104
/**

0 commit comments

Comments
 (0)