Kafka在IDEA中创建生产者及消费者(Scala版本)

目录

• 1、项目依赖关系
• 2、生产端实体
• 3、消费端实体
  • 3.1 建立消费端实体
  • 3.2 关注主题类型与分区策略
  • 3.3 设置自主提交模式与人工干预方式
  • 3.4 分析最早时间点（earliest）、最新时间点（latest）以及无指定（none）

1、项目依赖

本项目基于 Maven 开发，并且旨在调用 Kafka 的生产者 API。为此，必须导入 kafka-clients 依赖项，请参考相关配置说明。

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

2、生产者

Kafka Producer API配置项：

    import java.util.Properties
    import