java——spring boot集成kafka——java代码实现

矫情吗；* 2023-09-30 21:07 9阅读 0赞

![237bf31c0756e9d17261a19347f5cf42.png][]

![ae9c16f607cd1bea12868b9139105ae1.png][]

引入依赖：

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

⽣产者发送消息的基本实现

#### //消息的发送方
    public class MyProducer {
    
    private final static String TOPIC_NAME = "my-replicated-topic";
    
    public static void main(String[] args) throws ExecutionException,InterruptedException {
    Properties props = new Properties();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"10.31.167.10:9092,10.31.167.10:9093,10.31.167.10:9094");
    //把发送的key从字符串序列化为字节数组
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
    //把发送消息value从字符串序列化为字节数组
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());
    
    Producer<String, String> producer = new KafkaProducer<String,String>(props);
    
    Order order = new Order((long) i, i);
    ProducerRecord<String, String> producerRecord = new ProducerRecord<String, String>(TOPIC_NAME, order.getOrderId().toString(), JSON.toJSONString(order));
    RecordMetadata metadata = producer.send(producerRecord).get();
    //=====阻塞=======
    System.out.println("同步方式发送消息结果：" + "topic-" +metadata.topic() + "|partition-"+ metadata.partition() + "|offset-" +metadata.offset());

![271072c229a9cc5b03e4c0839048c5e3.png][]

![03856cd2835697d5d73321f316393754.png][]

[237bf31c0756e9d17261a19347f5cf42.png]: https://img-blog.csdnimg.cn/img_convert/237bf31c0756e9d17261a19347f5cf42.png
[ae9c16f607cd1bea12868b9139105ae1.png]: https://img-blog.csdnimg.cn/img_convert/ae9c16f607cd1bea12868b9139105ae1.png
[271072c229a9cc5b03e4c0839048c5e3.png]: https://img-blog.csdnimg.cn/img_convert/271072c229a9cc5b03e4c0839048c5e3.png
[03856cd2835697d5d73321f316393754.png]: https://img-blog.csdnimg.cn/img_convert/03856cd2835697d5d73321f316393754.png