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
相关文章
相关标签/搜索