R如何在调用rkafka.read时删除"INFO:请记住在读完消息后关闭消费者“

Question

我目前正在使用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}"

Answer 1

如果您想要捕获INFO消息，可以使用"capture.output“命令：

capture.output(rkafka.read(consumer))

您可以将消息放入变量中，然后将其丢弃，如下所示：

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