r如何在调用rkafka.read时删除“info:记住在读完消息后关闭消费者”

kb5ga3dv  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(271)

我目前正在使用r的Kafka-rkafka包。每次我读Kafka的文章时,我都会得到“信息:读完信息后记得关闭消费者”。我该怎么避免呢?

>library(rkafka)
>consumer<-rkafka.createConsumer("1.2.3.4:2181","Real-time-data", consumerTimeoutMs = "-1")
>rkafka.read(consumer)
[1] "INFO: Remember to close the consumer after done reading messages"
{\"type\":\"activity_log\",\"id\":0,\"group\":\"prod\",\"screen\":null,\"event\":null,\"time\":\"19:25:00\",\"region\":2657896}"
weylhg0b

weylhg0b1#

如果要捕获信息消息,可以使用“capture.output”命令:

capture.output(rkafka.read(consumer))

您可以将消息放入变量中,然后丢弃它,如下所示:

info_msg<-capture.output(rkafka.read(consumer)) 
rm(info_msg)

相关问题