demo_user2021/demo_consumer.R

library(kafkaesque)

consumer <- kafka_consumer()
consumer$start()
consumer$topics_list()
consumer$topics_subscribe("test")

consumer$consume_next()
consumer$consume_next()
consumer$consume_next()
consumer$consume_next()
petermeissner/kafkaesque documentation built on Sept. 28, 2022, 4:30 a.m.