国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > Java > 正文

Java使用kafka發送和生產消息的示例

2024-07-14 08:40:14
字體:
來源:轉載
供稿:網友

1. maven依賴包

<dependency>  <groupId>org.apache.java/276586.html">kafka</groupId>  <artifactId>kafka-clients</artifactId>  <version>0.9.0.1</version> </dependency> 

2. 生產者代碼

package com.lnho.example.kafka;  import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord;   import java.util.Properties;   public class KafkaProducerExample {  public static void main(String[] args) {   Properties props = new Properties();   props.put("bootstrap.servers", "master:9092");   props.put("acks", "all");   props.put("retries", 0);   props.put("batch.size", 16384);   props.put("linger.ms", 1);   props.put("buffer.memory", 33554432);   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 < 100; i++)    producer.send(new ProducerRecord<>("topic1", Integer.toString(i), Integer.toString(i)));     producer.close();  } } 

3. 消費者代碼

package com.lnho.example.kafka;   import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.KafkaConsumer; import java.util.Arrays; import java.util.Properties;   public class KafkaConsumerExample {  public static void main(String[] args) {   Properties props = new Properties();   props.put("bootstrap.servers", "master:9092");   props.put("group.id", "test");   props.put("enable.auto.commit", "true");   props.put("auto.commit.interval.ms", "1000");   props.put("session.timeout.ms", "30000");   props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");   props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");   KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);   consumer.subscribe(Arrays.asList("topic1"));   while (true) {    ConsumerRecords<String, String> records = consumer.poll(100);    for (ConsumerRecord<String, String> record : records)     System.out.printf("offset = %d, key = %s, value = %s/n", record.offset(), record.key(), record.value());   }  } } 

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VeVb武林網。


注:相關教程知識閱讀請移步到JAVA教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 巩留县| 锦屏县| 惠东县| 志丹县| 十堰市| 新兴县| 汝阳县| 准格尔旗| 北碚区| 洛浦县| 孙吴县| 濮阳市| 河津市| 于都县| 陆川县| 临澧县| 股票| 同心县| 时尚| 宜黄县| 平安县| 嘉祥县| 玉山县| 安康市| 徐水县| 龙南县| 宜昌市| 都兰县| 临汾市| 舟山市| 宁德市| 汉川市| 宿州市| 乐安县| 酉阳| 南漳县| 宝坻区| 綦江县| 高碑店市| 蒲江县| 沾益县|