toKotlin

fun toKotlin(javaType: StreamProcessorInput): StreamProcessorInput