c語言使用kafka消息隊列的實例

1.提供初始化以及收發消息接口,rd_kafka_msg.hnode #ifndef RDKAFKA_MSG_H_ #define RDKAFKA_MSG_H_ #include "rdkafka.h" int kafka_init(char mode, char* topic, int partion, char* brokers, rd_kafka_topic_conf_t **t
相關文章
相關標籤/搜索