kafka-connect-field-and-time-partitioner
kafka-connect-field-and-time-partitioner copied to clipboard
Fixed casting value from value field of field partitioner from float …
If the value of the custom partitioner field is an Long the casting to String throws the exception. "java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.String" This code should fix it.