4.1 环境准备

步骤1: 启动 Zookeeper 集群和 Kafka 集群

步骤2: 在 Kafka 集群中开启一个终端消费者

kafka-console-consumer.sh --zookeeper hadoop102:2181 --topic first

步骤3: 创建 maven 工程, 并导入相应的依赖

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>0.11.0.3</version>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.12</artifactId>
    <version>0.11.0.3</version>
</dependency>