# kafka-python

**Repository Path**: MrJson_yangkai/kafka-python

## Basic Information

- **Project Name**: kafka-python
- **Description**: kafka示例
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

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

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# Python Kafka 通知系统

这是一个基于Kafka的通知系统示例，用于演示如何使用Python和Kafka实现消息队列通知功能。

## 功能特点

- 支持多种通知类型（邮件、短信）
- 使用配置文件管理Kafka连接参数
- 实现了优雅的关闭机制
- 完善的错误处理和日志记录
- 生产者和消费者解耦设计

## 项目结构

```
.
├── config.py          # Kafka配置文件
├── producer.py        # 消息生产者
├── consumer.py        # 消息消费者
└── README.md          # 项目说明文档
```

## 安装依赖

```bash
pip install confluent-kafka
```

## 使用方法

### 1. 启动Kafka服务器

确保Kafka服务器已经启动并运行在localhost:9092（或修改config.py中的配置）。

### 2. 运行消费者

```bash
python consumer.py
```

### 3. 运行生产者发送消息

```bash
python producer.py
```

## 自定义配置

在`config.py`文件中可以修改Kafka的连接参数和主题配置：

```python
# Kafka服务器配置
KAFKA_CONFIG = {
    'bootstrap.servers': 'localhost:9092',
    # 其他配置...
}

# 主题配置
TOPICS = {
    'email': 'email-topic',
    'sms': 'sms-topic'
}
```

## 扩展开发

### 添加新的通知类型

1. 在`config.py`的`TOPICS`字典中添加新的主题
2. 在`consumer.py`中添加相应的处理函数
3. 使用`producer.py`中的`send_notification`函数发送新类型的通知

## 参考

https://blog.csdn.net/weixin_39810558/article/details/146986582