Add function documentation and error handling.
[R/project-using-kafka-in-R.git] / R /
drwxr-xr-x   ..
-rw-r--r-- 367 ConsumeKafkaMessages.R
-rw-r--r-- 1351 CreateKafkaConsumer.R
-rw-r--r-- 236 DestroyKafkaConsumer.R
-rw-r--r-- 548 ResetKafkaConsumerOffset.R
-rw-r--r-- 444 SubscribeKafkaTopic.R