# springbootKafkaDemo

**Repository Path**: qsh11/springboot-kafka-demo

## Basic Information

- **Project Name**: springbootKafkaDemo
- **Description**: springboot 整合kafka简单使用，kafka connector简单使用，kafka 读取mysql 简单使用，
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 6
- **Forks**: 0
- **Created**: 2023-11-06
- **Last Updated**: 2023-11-16

## Categories & Tags

**Categories**: Uncategorized

**Tags**: 程序开发, web应用开发

## README

# springbootKafkaDemo

#### 介绍
springboot 整合kafka简单使用，kafka connector简单使用，kafka 读取mysql 简单使用，

#### 软件架构
软件架构说明


#### 安装教程

1、官网下载最新版本的kafka，里面已经集成zookeeper。直接解压到D盘

2、配置文件修改，config目录下面的zookeeper.properties.   设置zookeeper数据目录

dataDir=D:/kafka_2.12-3.6.0/tmp/zookeeper


3、修改kafka的配置文件server.properties.   主要修改内容如下：

zookeeper.connect=localhost:2181

log.dirs=D:\\kafka_2.12-3.6.0\\logs

listeners=PLAINTEXT://localhost:9092

其他默认即可。

4、修改完成后进入bin目录：启动zookeeper和kafka，命令如下

zookeeper-server-start.bat ../../config/zookeeper.properties

kafka-server-start.bat ../../config/server.properties

5、命令行创建topic，命令如下：

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic hello

6、创建生产者和消费者，测试。生产者输入消息，消费者就会收到相应的消息了 

kafka-console-producer.bat --broker-list localhost:9092 --topic hello



kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic hello--from-beginning
7、启动connect服务器，读取text文件，注意设置文件目录文件名称
connect-standalone.bat  ../../config/connect-standalone.properties  ../../config/connect-file-source.properties 
connect-standalone.properties设置如下：
bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.file.filename=D:/kafka_2.12-3.6.0/tmp/connect.offsets
offset.flush.interval.ms=10000
connect-file-source.properties 设置如下：
name=local-file-source
connector.class=FileStreamSource
tasks.max=1
file=test.txt
topic=connect-test


#### 使用说明

mysql数据库链接改成自己的就行。

#### 参与贡献

1.  Fork 本仓库
2.  新建 Feat_xxx 分支
3.  提交代码
4.  新建 Pull Request


#### 特技

1.  使用 Readme\_XXX.md 来支持不同的语言，例如 Readme\_en.md, Readme\_zh.md
2.  Gitee 官方博客 [blog.gitee.com](https://blog.gitee.com)
3.  你可以 [https://gitee.com/explore](https://gitee.com/explore) 这个地址来了解 Gitee 上的优秀开源项目
4.  [GVP](https://gitee.com/gvp) 全称是 Gitee 最有价值开源项目，是综合评定出的优秀开源项目
5.  Gitee 官方提供的使用手册 [https://gitee.com/help](https://gitee.com/help)
6.  Gitee 封面人物是一档用来展示 Gitee 会员风采的栏目 [https://gitee.com/gitee-stars/](https://gitee.com/gitee-stars/)