# springboot-kafka

**Repository Path**: yong-hu/springboot-kafka

## Basic Information

- **Project Name**: springboot-kafka
- **Description**: springboot集成kafka demo实例
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 4
- **Forks**: 1
- **Created**: 2022-05-18
- **Last Updated**: 2023-06-27

## Categories & Tags

**Categories**: Uncategorized

**Tags**: SpringBoot, Kafka

## README

# springboot-kafka

#### 介绍
springboot集成kafka demo实例介绍

基于 kafka_2.13-2.7.1.tgz apache-zookeeper-3.5.9-bin.tar.gz 版本

安装包见 src/zip
#### 软件架构
基于SpringBoot开发，支持kafka工具样例实现

#### 安装教程
无

#### 使用说明
**`spring-boot 集成kafka demo 实例`**   
`版本内容包括：`   
1：**springboot 整合kafka**    

2：**kafka 生产者与消费者的工厂参数配置**  
    (自定义配置见：application.properties  自定义配置见：com.huyong.spring_boot_kafka.util.KafkaConfiguration)     

3：**生产者实例demo，包含：**     
    默认方式推送  
    回调方式发送  
    普通事务方式发送    
    实现Callback事务回调方式发送  

4：**消费者实例demo，包含：**  
    指定topic普通方式消费   
    并发消费    

5：**kafka异常捕获**     

6: **代码实现kafka的topic创建，删除，分区修改**        

7：**kafka初始化主题、分区、副本设置**
  com.huyong.spring_boot_kafka.util.KafkaInitialConfiguration
   
8：**代码实现kafka的topic创建，删除，分区修改**
   com.huyong.spring_boot_kafka.util.KafkaOperationUtil
  
9：**kafka消息自定义分区策略发送**
  com.huyong.spring_boot_kafka.util.PartitionerConfiguration
   
**kafka、zk单机搭建、集群搭建介绍：**    
  https://blog.csdn.net/qq_36963950/article/details/123289400

#### 参与贡献

1.  Fork 本仓库
3.  提交代码


#### 特技