Kafka用IDEA来创建生产者和消费者（Java版本）

目录

• 1、项目依赖

  • 2、生产者

  • • 2.1 生产者实例的构建
    • 2.2 功能验证

  • 3、消费者

  • • 3.1 消费者及其所属群组
    • 3.2 分区分配机制
    • 3.3 消费者实例的建立

1、项目依赖

本项目基于 Maven 进行构建，如需调用 Kafka 生产者 API，必须引入 kafka-clients 依赖库，具体操作如下：

    <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>
       <version>2.0.0</version>
    </dependency>
    
    
      
      
      
      
      
    

2、生产者角色分析

2.1 创建生产者

在构建 Kafka 生产者时，有三个关键属性是必须明确设置的：

• bootstrap.servers ：用于定义 broker 的地址列表，该列表中无需包含全部的 broker 地址，生产者将从提供的 broker 中获取相关信息。但为了确保系统的