Scala Code: ``` val momentSource: FlinkKafkaConsu...

# announcements

[otang]

Scala Code:

val momentSource: FlinkKafkaConsumer09[Moment] = kafkaFactory.createSpecific(classOf[Moment])`

Calling Kotlin Code:

fun <T : SpecificRecordBase> createSpecific(avroType: Class<T>): FlinkKafkaConsumer09<T> {
        val name = SpecificData.get().getSchema(avroType).fullName
        return FlinkKafkaConsumer09(name, SerdesSpecificAvroDeserializer(avroType), properties)
    }