Scala Kinesis Enrich: add Kafka source