# KafkaServerDemo

**Repository Path**: ccae-sdk/KafkaServerDemo

## Basic Information

- **Project Name**: KafkaServerDemo
- **Description**: 介绍如何搭建用户自有的Kafka Server简易工程，通过CCAE北向Kafka Client接口实现故障数据上报接收解析，快速构建CCAE北向‘Hello World’示例。
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2025-05-07
- **Last Updated**: 2025-05-16

## Categories & Tags

**Categories**: Uncategorized

**Tags**: CCAE, Kafka, client, Server, 消费者

## README

# KafkaServerDemo使用说明书
### 简介：

本文将介绍如何搭建一个简易的Kafka Server项目并使用它来完成CCAE北向的Kafka接口对接。

### 运行环境：

```
1、windows10及其以上版本
2、JDK版本 Java 1.8
```

### 项目下载：

```
git clone https://gitee.com/ccae-sdk/KafkaServerDemo.git
```

### Kafka服务端配置：

打开工程，找到 kafka -> config -> server.properties 文件，配置 Kafka 服务器的监听地址和端口。如：

```properties
#填写与CCAE互通的IP地址，端口可以自行指定空闲的端口
listeners=PLAINTEXT://192.168.0.100:9892
```

### Kafka客户端配置：

打开工程，找到 src-> main -> resource -> application.yaml 文件。

配置监听地址和端口：spring -> kafka -> bootstrap-servers。

```yaml
spring:
  kafka:
    bootstrap-servers: 192.168.0.100:9892  #正常情况下，此IP地址和端口需要和Kafka服务端端口可通讯，本地调试代码时可将IP地址和端口设置为和 “Kafka服务端配置” 章节一致，如：192.168.0.100:9892
```

配置监听的topic：kafka -> topic。

```yaml
kafka:
  topic: mobileAlarm  #根据实际需要监听的Topic填写，如：mobileAlarm
```

### 启动项目：

启动项目前确保Maven依赖已引入。

1、启动Kafka：

运行KafkaZookeeperStarter.java。

出现下列日志表示Kafka启动成功

![img](./imgage/562b16c8cf3f0ab75c167b78075df156_2480x646.png)

2、启动Kafka消息监听：

运行SwaggerApplication.java。

下列日志表示Kafka消息监控启动成功。

![img](./imgage/a23c9d4ccc05b695a9f01e0061ff5cfc_2460x765.png)

### 环境对接配置：

1、在CCAE业务面主菜单中选择“系统 > 系统设置 > 北向接口”。在左侧导航树中选择“Kafka接口”，单击 “创建”。

2、在“Kafka服务端地址”栏，单击 “增加”。

3、输入对接Kafka信息，IP地址和端口保持和“Kafka服务端配置”章节一致（需要保证网络连通性）。

4、配置“安全配置”及Topic， 本demo不进行Kafka证书校验，“认证模式”选择“PLAINTEXT”。

5、 单击“连通性检测”， 出现"连通性检测成功"弹窗证明网络通畅，单击“保存”完成Kafka对接配置。

### 验证Kafka消息接收：

对接成功后，当系统中产生告警时，Kafka消息监听控制台打印出Kafka消息即证明Topic上报后OSS接收成功。

![img](./imgage/7cfd7588aa6974328a7cf5356b083bfc_2502x360.png)