依赖
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> </dependency>
代码
package com.perfect.kafka; import org.apache.kafka.clients.producer.*; import org.junit.jupiter.api.Test; import java.util.Properties; public class KafkaCallbackProducerTest { @Test public void sendmessagetest(){ Properties props = new Properties(); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092"); props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer"); props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer<String,String> p = new KafkaProducer<String, String>(props); for(int i=0;i<10;i++){ p.send(new ProducerRecord<>("topic2", "message" + i), new Callback() { @Override public void onCompletion(RecordMetadata recordMetadata, Exception e) { if(e==null){ System.out.println(recordMetadata.partition()+"---"+recordMetadata.offset()); } } }); } p.close(); } }
原文:https://www.cnblogs.com/abuduri/p/13342020.html