# kafka_example

**Repository Path**: deng-c-f/kafka_example

## Basic Information

- **Project Name**: kafka_example
- **Description**: kafka的c++代码
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-03-07
- **Last Updated**: 2026-03-08

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# kafka_example

#### 介绍
kafka的c++代码  
生产者：3个版本：单线程处理消息、线程池处理消息、线程池处理消息+手动提交已处理好业务的消息的offset（而非拉取的offset）  
消费者：2个版本：单线程投递消息、线程池投递消息  

#### 安装教程
kafka版本：kafka_2.11-2.0.0 


#### 使用说明

1.  打开zookeeper
2.  打开kafka服务器
3.  手动生成主题
4.  运行producer代码 （cmake生成）
5.  运行consumer代码（cmake生成）