How to Connect Kafka and Sparklyr to process streaming data?