# springboot-kafka

**Repository Path**: xingji_java/springboot-kafka

## Basic Information

- **Project Name**: springboot-kafka
- **Description**: springboot集成kafka
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2024-05-14
- **Last Updated**: 2024-05-16

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# springboot-kafka

#### 介绍
springboot集成kafka

#### 软件架构
a-producter:生产者模块，用于发消息
b-customer:消费者模块，用于监听消息

#### 安装教程

1.  docker中安装kafka集群，使用docker文件夹中的yml
2.  启动a-producter
3.  启动b-customer
4.  生产者发送消息，消费者监听消息，查看kafka状态

#### 注意
生成者 可以用这个来做测试

#### 教程
[springboot集成kafka（docker）](https://blog.csdn.net/wayhb/article/details/122475059)

CREATE TABLE `residents_base_info` (
  `id` bigint NOT NULL AUTO_INCREMENT COMMENT '居民ID',
  `tenant_id` bigint NOT NULL DEFAULT '0' COMMENT '租户编号',
  `mobile` varchar(11) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '居民联系方式',
  `name` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '居民姓名',
  `source` tinyint NOT NULL DEFAULT '3' COMMENT '来源（1预警劝阻 2宣传防范 3手动导入 3人工接警 4智能接警 5接口导入）',
  `latest_reach_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '最近触达时间',
  `status` tinyint NOT NULL DEFAULT '0' COMMENT '居民状态（0-未接收 1-已接收）',
  `responsible_id` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT '' COMMENT '负责人Id',
  `lables` varchar(1024) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci NOT NULL COMMENT '标签组/列',
  `extend_info` text COMMENT '扩展信息',
  `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
  `update_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
  `is_deleted` bit(1) NOT NULL DEFAULT b'0' COMMENT '是否删除',
  PRIMARY KEY (`id`) USING BTREE,
  INDEX `idx_mobile`(`tenant_id` ASC, `mobile` ASC) USING BTREE COMMENT '租户-居民手机号'
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='居民信息表';