2017-10-04 4 views
0

J'utilise actuellement le paquet R pour kafka - rkafka. Chaque fois que je lis de Kafka, je reçois "INFO: N'oubliez pas de fermer le consommateur après avoir lu les messages". Comment puis-je éviter cela?R Comment supprimer "INFO: N'oubliez pas de fermer le consommateur après avoir lu les messages" lors de l'appel rkafka.read

>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}" 
+0

Avez-vous trouvé une autre solution? Je pourrais être intéressé. –

Répondre

0

Si vous voulez capturer le message INFO vous pouvez utiliser la commande "capture.output":

capture.output(rkafka.read(consumer)) 

Vous pouvez mettre le message dans une variable puis jeter, comme ceci:

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