这个api-rd\u kafka\u poll\u set\u consumer（）的目的是什么？在rdkafka.h文件中，它表示一旦您将rd\u kafka\u poll队列（rk->rep）重定向到rd\u kafka\u consumer\u poll的队列（rkcg->rkcg\u q），您就不应该在这之后调用rd\u kafka\u poll。
有人能详细说明一下哪个队列发生了什么吗？制作人是否应该调用rd\U kafka\U consumer\U poll来查看生成的消息？
这个api-rd\u kafka\u poll\u set\u consumer（）的目的是什么？在rdkafka.h文件中，它表示一旦您将rd\u kafka\u poll队列（rk->rep）重定向到rd\u kafka\u consumer\u poll的队列（rkcg->rkcg\u q），您就不应该在这之后调用rd\u kafka\u poll。
有人能详细说明一下哪个队列发生了什么吗？制作人是否应该调用rd\U kafka\U consumer\U poll来查看生成的消息？
1条答案
按热度按时间9rbhqvlz1#
rd_kafka_poll_set_consumer()转发通常由rd_kafka_poll()（如error\u cb、stats\u cb等）发送到rd_kafka_consumer_poll().这简化了应用程序轮询循环，因为它将能够为标准回调提供服务，并且只使用一个调用来接收消息
rd_kafka_consumer_poll()而不是打电话rd_kafka_poll().顾名思义，此事件队列重新路由只对使用者感兴趣，生产者应用程序仍应调用
rd_kafka_poll()为医生等服务。