kRafka

Wrapper for apache kafka consumer in R

To install, run (requires rJava):

install_github("Ehmeed/kRafka/R")

To read topic messages, run:

df = kRafka.read("localhost:9093", "topic_name", type = "datetime", from = "1970-01-01T00:00:00.00Z", to = "2037-01-01T00:00:00.00Z")

To list topics, run:

kRafka.listTopics("localhost:9093")

Also supports custom deserializers and other consumer configs. See the source.