我目前正在使用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}"
1条答案
按热度按时间weylhg0b1#
如果要捕获信息消息,可以使用“capture.output”命令:
您可以将消息放入变量中,然后丢弃它,如下所示: