Kafka简单案例之异步发送消息_kafka 异步提交实战案例

一. 案例需求

使用IDEA工具创建Maven项目编写API
Producer端采用异步生产发送消息
Consumer端在虚拟机开启窗口消费数据

二. 异步发送API实战

1. 导入Kafka的依赖

<dependencies>
        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>0.11.0.0</version>
        </dependency>
</dependencies>
1
2
3
4
5
6
7

2. 代码编写

1). 不带回调函数的API

package com.learn.kafka;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class TestProducer {
   
    public static void main(String[] args) {
   

        //参数配置
        //创建配置对象
        Properties prop = new Properties();
        //指定Kafka集群的主机名和端口号
        prop.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18