概述

  生产者API使用实践

官网：producerapi

实践

代码

命令行消费端

代码

public class KafkaProducerApp {public static void main(String[] args) {Properties props = new Properties();props.put("bootstrap.servers", "hadoop02:9092");props.put("linger.ms", 1);props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");Producer<String, String> producer = new KafkaProducer<>(props);for (int i = 0; i < 5; i++)producer.send(new ProducerRecord<String, String>("test01", Integer.toString(i), Integer.toString(i)));producer.close();}
}

效果

代码优化