国产探花免费观看_亚洲丰满少妇自慰呻吟_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教程頻道。
發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 平武县| 宁远县| 大理市| 聂拉木县| 姚安县| 正阳县| 乌海市| 彩票| 泾川县| 中阳县| 承德县| 民县| 玛曲县| 香港 | 永济市| 日土县| 五河县| 兴城市| 镇江市| 阳江市| 沅陵县| 正蓝旗| 茌平县| 西平县| 本溪市| 合水县| 巴林左旗| 渑池县| 定兴县| 广德县| 西贡区| 涟水县| 张家港市| 巴彦淖尔市| 云林县| 独山县| 平山县| 西昌市| 台南县| 德惠市| 新宁县|