我有不同的线程产生一个消息给Kafka和其他线程只轮询Kafka检查传递报告或事件。问题是，dr\u cb（）方法将在哪个线程上执行？它是在原始的produce线程上执行还是在轮询线程上执行？如果在原始的produce线程上调用dr\u cb，它会中断当前的执行吗？
h4cxqtbf1#
传递报告回调，以及大多数其他回调( log_cb 在应用程序调用时从应用程序线程触发 rd_kafka_poll() 或者 rd_kafka_flush() .介绍文件对此进行了解释。
log_cb
rd_kafka_poll()
rd_kafka_flush()
1条答案
按热度按时间h4cxqtbf1#
传递报告回调，以及大多数其他回调(
log_cb在应用程序调用时从应用程序线程触发rd_kafka_poll()或者rd_kafka_flush().介绍文件对此进行了解释。