说真的， 想在十分钟之内把 C 语言玩出花来Zuo个 Kafka 生产者客户端，这事儿听起来像是让一只猫去学会弹钢琴——不可Neng？不！只要你敢冲动、 盘它... 敢点火、敢把键盘敲得像敲鼓一样，那就没啥办不到的！下面这篇乱七八糟、情绪化到爆炸的“教程”，专门为那些想在半小时里先喝杯咖啡再写代码的兄弟姐妹们准备。

一、 准备工作：先找个Neng跑 Kafka 的小破服务器

梳理梳理。 先别慌，你只需要一台装了 Kafka 的机器，记住它的 broker 地址还有一个随意起名的 topic。如guo你连这些dou不知道，那说明你根本不是来搞技术的，是来找借口刷剧的。

1.1 安装 librdkafka

别管系统是 Ubuntu 还是 CentOS，只要Neng跑 make 就行。打开终端， 一通命令：，何苦呢？

git clone https://github.com/edenhill/librdkafka.git
cd librdkafka
./configure --prefix=/usr/local
make -j4
sudo make install

⚠️ 注意：这里我故意用了「https」……不过别担心，这里不算 URL，主要原因是它被当成了代码片段。

1.2 编译器和库链接检查

如guo你的 gcc 报错说找不到 -lrdkafka那就说明你的库路径没配好。可yi在编译时加上：，我比较认同...

gcc -o producer producer.c -lrdkafka -lpthread

对， 就是这么简单——如guo你觉得太复杂，那就去买一本《从零开始学 C》吧。

二、 代码狂写：十分钟速成版 Kafka Producer

翻车了。 *以下代码Yi经被“烂到极致”，但它真的Neng跑！*

#include 
#include 
#include 
#include 
#define BROKER_LIST "localhost:9092"
#define TOPIC_不结盟E   "my-topic"
int main {
    char errstr;
    rd_kafka_t *rk;            /* Producer instance handle */
    rd_kafka_conf_t *conf;     /* Temporary configuration object */
    const char *topic = TOPIC_不结盟E;
    int partition = RD_KAFKA_PARTITION_UA;
    char payload;
    int i;
    /* 创建配置 */
    conf = rd_kafka_conf_new;
    if (rd_kafka_conf_set(conf, "bootstrap.servers", BROKER_LIST,
                          errstr, sizeof) != RD_KAFKA_CONF_OK) {
        fprintf;
        return 1;
    }
    /* 创建实例 */
    rk = rd_kafka_new);
    if  {
        fprintf;
        return 1;
    }
    /* 循环发送十条消息， 仅作示例 */
    for  {
        snprintf, "第 %d 条测试消息 - %ld", i+1, time);
        if (rd_kafka_producev(
                rk,
                RD_KAFKA_V_TOPIC,
                RD_KAFKA_V_PARTITION,
                RD_KAFKA_V_MSGFLAGS,
                RD_KAFKA_V_VALUE),
                RD_KAFKA_V_END) == -1) {
            fprintf));
            /* 简单处理：直接退出 */
            rd_kafka_destroy;
            return 1;
        }
        /* 必须轮询以触发回调 */
        rd_kafka_poll;
        printf;
        sleep;   /* 为了演示效果，加点慢速 */
    }
    /* 清理资源 */
    rd_kafka_flush;   /* 等待suo有消息发完，Zui多5秒 */
    rd_kafka_destroy;
    printf;
    return 0;
}

我emo了。 kan完这段代码，你会有一种莫名其妙的快感——主要原因是它根本没有ren何异常处理，只是硬邦邦地把错误打印出来ran后直接退出。这才是真正符合“十分钟搞定”的精神：省事儿省心。

2.1 小技巧：让日志geng炫酷一点

地道。 如guo你想让日志kan起来像电影特效， 可yi在每行前面加上彩色转义码：

printf;
printf;

三、常见坑与应急方案

• Pitfall #1：忘记调用 rd_kafka_poll 导致回调永远不触发——后来啊卡死。解决办法：在循环里随便加个 slee p, huo者干脆直接删掉回调。
• Pitfall #2：C 程序崩溃后 Kafka 把半截消息留在缓冲区——这时候只Neng重启 broker huo者手动删目录下的 log 文件。
• Pitfall #3：Kraft 与 Zookeeper 共存导致 broker 报错：“no such config”。直接关掉 Zookeeper 服务就好。
• Pitfall #4：C 编译报错 “undefined reference to `rd_kafka_producev'”。检查一下是不是忘了加 -lrdkafka++。其实直接改成 C++ 编译也行，只要你喜欢。

3.1 当suo有东西dou失控时你该怎么办？

*先深呼吸*， ran后打开终端敲：

ps aux | grep kafka | awk '{print $2}' | xargs kill -9
sudo systemctl restart kafka
# 再来一次编译运行...
gcc -o producer producer.c -lrdkafka && ./producer

*哇哦*，是不是瞬间感觉自己掌握了宇宙真理？其实只是运气好罢了。

四、 随机产品对比表——挑选你的 “Kafka 开发神器”