// 对rd_kafka_topic_partition_list_t结构的操作

 // 创建

 rd_kafka_topic_partition_list_new();

 // 增加元素

 rd_kafka_topic_partition_list_add();

 // 删除元素

 rd_kafka_topic_partition_list_del();

 // 查找元素

 rd_kafka_topic_partition_list_find();

 // 对rd_kafka_topic_t的操作

 // 创建

 rd_kafka_topic_new();

 // 删除

 rd_kafka_topic_destroy();

 // 获取该topic的名字

 rd_kafka_topic_name();

 // 获取该topic传入的应用参数

 rd_kafka_topic_opaque();

 // 使用rd_kafka_topic_partition_list_t的时候，topic+partition是连在一起的，

 // 所以给kafka句柄的时候只用一个参数就够了

 // 订阅消息

 rd_kafka_subscribe (rd_kafka_t *rk,

                             const rd_kafka_topic_partition_list_t *topics);

 // 指定消费的partition，可以在运行时更换

 rd_kafka_assign (rd_kafka_t *rk,

                             const rd_kafka_topic_partition_list_t *partitions);

 // 用rd_kafka_topic_t比较麻烦，需要配合一个partition才行

 // 直接启动consumer了

 rd_kafka_consume_start(rd_kafka_topic_t *rkt, int32_t partition,

                             int64_t offset);

 // 每次接收也要带上partition

 rd_kafka_message_t *rd_kafka_consume(rd_kafka_topic_t *rkt, int32_t partition,

                             int timeout_ms);

 // 发送的时候使用 rd_kafka_topic_t

 int rd_kafka_produce(rd_kafka_topic_t *rkt, int32_t partition,

                             int msgflags,

                             void *payload, size_t len,

                             const void *key, size_t keylen,

                             void *msg_opaque);