R如何刪除「INFO：記得在完成閱讀消息後關閉消費者」時調用rkafka.read

Question

我目前正在使用R包kafka - rkafka。每當我從卡夫卡讀取時，我都會收到「信息：記得在完成閱讀信息後關閉消費者」。我如何避免這種情況？

>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

如果你想捕捉您可以使用「capture.output」命令INFO消息：

capture.output(rkafka.read(consumer)) 

你可以把信息中的變量，然後丟棄它，就像這樣：

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