# java-kafka

**Repository Path**: JacksonCodes/java-kafka

## Basic Information

- **Project Name**: java-kafka
- **Description**: No description available
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-12-07
- **Last Updated**: 2025-12-07

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# 🚀 Kafka Spring Boot 项目

## 📋 项目概述
Kafka Spring Boot 演示项目，包含生产者和消费者功能。

## 🚀 快速开始

### 1. 启动 Kafka 服务
```bash
# 使用修复后的配置启动 Kafka 和 Kafka UI
start-kafka.bat
```

### 2. 启动 Spring Boot 应用
```bash
# 启动应用（端口 8082）
mvn spring-boot:run
```

### 3. 访问服务
- **应用地址**: http://localhost:8082
- **Kafka UI**: http://localhost:8080
- **测试界面**: 打开 `test_kafka.html`

## 📡 API 端点

### 消息发送
- `GET /send/simple?message={消息}` - 发送简单消息
- `GET /send/topic?topic={主题}&message={消息}` - 发送到指定主题
- `POST /send/full` - 发送完整消息（JSON格式）
- `GET /send/multiple?message={消息}` - 发送到多个主题

### 状态查询
- `GET /health` - 健康检查
- `GET /topic/default` - 获取默认主题
- `GET /consumer/stats` - 消费者统计

## 🛠️ 配置文件

### Docker 配置
- `docker-compose.yaml` - 原始配置（有问题的）
- `docker-compose-fixed.yaml` - 修复后的完整配置

### 应用配置
- `src/main/resources/application.yml` - Spring Boot 配置
- 端口：8082
- Kafka 服务器：localhost:9092

## 🧪 测试

### 测试 Kafka 服务
```bash
test-kafka.bat
```

### 测试 API
使用浏览器打开 `test_kafka.html` 进行可视化测试。

## 📊 服务地址

| 服务 | 地址 | 说明 |
|------|------|------|
| Spring Boot 应用 | http://localhost:8082 | 主应用 |
| Kafka Bootstrap | localhost:9092 | Kafka 服务器 |
| Kafka UI | http://localhost:8080 | Kafka 管理界面 |

## 🔧 常用命令

### Kafka 命令行
```bash
# 创建主题
docker exec kafka kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

# 列出主题
docker exec kafka kafka-topics.sh --list --bootstrap-server localhost:9092

# 发送消息
docker exec -it kafka kafka-console-producer.sh --topic test-topic --bootstrap-server localhost:9092

# 接收消息
docker exec -it kafka kafka-console-consumer.sh --topic test-topic --bootstrap-server localhost:9092 --from-beginning
```

### Docker 管理
```bash
# 停止服务
docker-compose -f docker-compose-fixed.yaml down

# 查看日志
docker-compose -f docker-compose-fixed.yaml logs -f kafka
```

## ⚠️ 注意事项

1. **端口冲突**: 确保端口 8080、8082、9092 未被占用
2. **内存要求**: Kafka 需要至少 1GB 内存
3. **启动顺序**: 先启动 Kafka，再启动 Spring Boot 应用

## 🎯 下一步

1. 测试消息发送功能
2. 恢复消费者功能（当需要时）
3. 监控 Kafka 性能指标
4. 配置生产环境参数

## 📚 相关文件

- `test_kafka.html` - 测试界面
- `start-kafka.bat` - Kafka 启动脚本
- `test-kafka.bat` - Kafka 测试脚本
- `docker-compose-fixed.yaml` - 修复后的 Docker 配置