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

kb5ga3dv 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(286)

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

apache-kafka kafka-consumer-api r rkafka

来源：https://stackoverflow.com/questions/46570580/r-how-to-remove-info-remember-to-close-the-consumer-after-done-reading-message

1条答案

按热度按时间

weylhg0b1#

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

capture.output(rkafka.read(consumer))

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

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

赞(0）回复(0）举报 2021-06-07

我来回答

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

1条答案

相关问题

热门标签

最新问答