Shulou(Shulou.com)06/03 Report--

1. Simulate the producer-consumer (native API) implementation of kafka to address related dependencies: org.apache.kafka kafka_2.12 2.1.0

Producer:

Packagecom.zy.kafka;importjava.util.Properties;importorg.apache.kafka.clients.producer.KafkaProducer;importorg.apache.kafka.clients.producer.Producer;importorg.apache.kafka.clients.producer.ProducerRecord;publicclassKafkaTest {publicstaticvoidmain (String [] args) {/ / 1. Load configuration file / / 1.1Encapsulation profile object Properties prps=newProperties (); / configure broker address prps.put ("bootstrap.servers", "hadoop02:9092"); / / configure ack level: 0 1-1 (all) prps.put ("acks", "all"); / / number of retries prps.put ("retries", 3) Prps.put ("batch.size", 16384); prps.put ("linger.ms", 1); prps.put ("buffer.memory", 33554432); / / specify the serialization prps.put ("key.serializer", "org.apache.kafka.common.serialization.StringSerializer") of (Kmuri V of message); prps.put ("value.serializer", "org.apache.kafka.common.serialization.StringSerializer") / / 2. Create producer object (generic of specified key and value) Producerproducer=new KafkaProducer (prps); / / producer sends message for (inti=0;i)

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.