node.js 基本語法識記
阿新 • • 發佈:2021-10-21
1.第一種(傳送並忘記)
ProducerRecord<String,String> record = new ProducerRecord<String,String>("topic",1,"TestProducer"); // 主題,key,value Propertis properties = new Properties(); properties.put("bootstrap.servers","127.0.0.1:9092");; properties .put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties .put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer kafkaProducer = new KafkaProducer<>(properties ); kafkaProducer .send(record ) //傳送並忘記
1.第二種(同步阻塞)
ProducerRecord<String,String> record = new ProducerRecord<String,String>("topic",1,"TestProducer"); Propertis properties= new Properties(); properties.put("bootstrap.servers","127.0.0.1:9092");; properties .put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties .put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); KafkaProducer kafkaProducer = new KafkaProducer<>(properties ); Future<RecordMetadata> recordMetadata=kafkaProducer.send(record); // 阻塞在這個未知
if (null != recordMetadata){
System.out.println("offset:" + recordMetadata.offset() + "-" + "partition:" + recordMetadata.partition());
}