2024-10-31 stan

1. 背景分析

通过分析matchengine源码，特别是me_message.c(行1-176)可以看出，系统使用Kafka作为消息队列，主要用于处理以下三类消息：

• balances (余额变更)
• orders (订单更新)
• deals (交易完成)

2. Kafka安装配置

2.1 基础环境准备

# 安装Java环境
apt update
apt install -y default-jdk

# 验证Java安装
java -version

2.2 Kafka安装

cd /opt
wget <https://downloads.apache.org/kafka/3.8.1/kafka_2.13-3.8.1.tgz>
tar xzf kafka_2.13-3.8.1.tgz
mv kafka_2.13-3.8.1 kafka

2.3 Kafka配置

编辑/opt/kafka/config/server.properties:

# 监听配置
listeners=PLAINTEXT://127.0.0.1:9092
advertised.listeners=PLAINTEXT://127.0.0.1:9092

# 数据存储配置
log.dirs=/opt/kafka/data

# 默认分区数
num.partitions=1

# 默认副本因子
default.replication.factor=1

3. 服务启动

3.1 启动Zookeeper

cd /opt/kafka
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

3.2 启动Kafka

bin/kafka-server-start.sh -daemon config/server.properties

4. Topic创建与验证