Skip to content

Commit be1bee9

Browse files
committed
Added transformation to convert numeric values to a int64 Fixes jcustenborder#19.
1 parent 84c9c4a commit be1bee9

File tree

1 file changed

+1
-1
lines changed
  • src/main/java/com/github/jcustenborder/kafka/connect/transform/common

1 file changed

+1
-1
lines changed

src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ToLong.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public abstract class ToLong<R extends ConnectRecord<R>> extends BaseTransformat
3838

3939
@Override
4040
public ConfigDef config() {
41-
return BytesToStringConfig.config();
41+
return ToLongConfig.config();
4242
}
4343

4444
ToLongConfig config;

0 commit comments

Comments
 (0)