中文亚洲精品无码_熟女乱子伦免费_人人超碰人人爱国产_亚洲熟妇女综合网

當(dāng)前位置: 首頁(yè) > news >正文

慈溪高端網(wǎng)站設(shè)計(jì)百度貼吧怎么做推廣

慈溪高端網(wǎng)站設(shè)計(jì),百度貼吧怎么做推廣,昭通做網(wǎng)站公司,做紙貿(mào)易的好網(wǎng)站目錄 一、獨(dú)立消費(fèi)者消費(fèi)某一個(gè)主題中某個(gè)分區(qū)數(shù)據(jù)案例1.1、案例需求1.2、案例代碼1.3、測(cè)試 一、獨(dú)立消費(fèi)者消費(fèi)某一個(gè)主題中某個(gè)分區(qū)數(shù)據(jù)案例 1.1、案例需求 創(chuàng)建一個(gè)獨(dú)立消費(fèi)者,消費(fèi)firstTopic主題 0 號(hào)分區(qū)的數(shù)據(jù),所下圖所示: 1.2、案…

目錄

    • 一、獨(dú)立消費(fèi)者消費(fèi)某一個(gè)主題中某個(gè)分區(qū)數(shù)據(jù)案例
      • 1.1、案例需求
      • 1.2、案例代碼
      • 1.3、測(cè)試

一、獨(dú)立消費(fèi)者消費(fèi)某一個(gè)主題中某個(gè)分區(qū)數(shù)據(jù)案例

1.1、案例需求

  • 創(chuàng)建一個(gè)獨(dú)立消費(fèi)者,消費(fèi)firstTopic主題 0 號(hào)分區(qū)的數(shù)據(jù),所下圖所示:
    在這里插入圖片描述

1.2、案例代碼

  • 生產(chǎn)者往firstTopic主題 0 號(hào)分區(qū)發(fā)送數(shù)據(jù)代碼

    package com.xz.kafka.producer;import org.apache.kafka.clients.producer.*;
    import org.apache.kafka.common.serialization.StringSerializer;
    import java.util.Properties;public class CustomProducerCallback {public static void main(String[] args) throws InterruptedException {//1、創(chuàng)建 kafka 生產(chǎn)者的配置對(duì)象Properties properties = new Properties();//2、給 kafka 配置對(duì)象添加配置信息:bootstrap.serversproperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"192.168.136.27:9092,192.168.136.28:9092,192.168.136.29:9092");//3、指定對(duì)應(yīng)的key和value的序列化類(lèi)型 key.serializer value.serializerproperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());//4、創(chuàng)建 kafka 生產(chǎn)者對(duì)象KafkaProducer<String, String> kafkaProducer = new KafkaProducer<>(properties);//5、調(diào)用 send 方法,發(fā)送消息for (int i = 0; i < 5; i++) {kafkaProducer.send(new ProducerRecord<>("firstTopic", 0,"","hello kafka" + i), new Callback() {@Overridepublic void onCompletion(RecordMetadata metadata, Exception exception) {if (exception == null){System.out.println("主題: "+metadata.topic() + " 分區(qū): "+ metadata.partition());}}});Thread.sleep(2);}// 3 關(guān)閉資源kafkaProducer.close();}
    }
  • 消費(fèi)者消費(fèi)firstTopic主題 0 分區(qū)數(shù)據(jù)代碼

    package com.xz.kafka.consumer;import org.apache.kafka.clients.consumer.ConsumerConfig;
    import org.apache.kafka.clients.consumer.ConsumerRecord;
    import org.apache.kafka.clients.consumer.ConsumerRecords;
    import org.apache.kafka.clients.consumer.KafkaConsumer;
    import org.apache.kafka.common.TopicPartition;
    import org.apache.kafka.common.serialization.StringDeserializer;import java.time.Duration;
    import java.util.ArrayList;
    import java.util.Properties;public class CustomConsumerPartition {public static void main(String[] args) {// 配置Properties properties = new Properties();// 連接properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"192.168.136.27:9092,192.168.136.28:9092,192.168.136.29:9092");// 反序列化properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());// 組idproperties.put(ConsumerConfig.GROUP_ID_CONFIG,"test");// 1 創(chuàng)建一個(gè)消費(fèi)者KafkaConsumer<String, String> kafkaConsumer = new KafkaConsumer<>(properties);// 2 訂閱主題對(duì)應(yīng)的分區(qū)ArrayList<TopicPartition> topicPartitions = new ArrayList<>();topicPartitions.add(new TopicPartition("firstTopic",0));kafkaConsumer.assign(topicPartitions);// 3 消費(fèi)數(shù)據(jù)while (true){ConsumerRecords<String, String> consumerRecords = kafkaConsumer.poll(Duration.ofSeconds(1));for (ConsumerRecord<String, String> consumerRecord : consumerRecords) {System.out.println(consumerRecord);}}}
    }
    

1.3、測(cè)試

  • 在 IDEA 中執(zhí)行消費(fèi)者程序,如下圖:
    在這里插入圖片描述
  • 在 IDEA 中執(zhí)行生產(chǎn)者程序 ,在控制臺(tái)觀察生成幾個(gè) 0號(hào)分區(qū)的數(shù)據(jù),如下圖:
    在這里插入圖片描述
  • 在 IDEA 控制臺(tái),觀察接收到的數(shù)據(jù),只能消費(fèi)到 0 號(hào)分區(qū)數(shù)據(jù)表示正確。
    在這里插入圖片描述
http://www.risenshineclean.com/news/11080.html

相關(guān)文章:

  • 產(chǎn)品網(wǎng)站系統(tǒng)溫州最好的seo
  • 怎樣做網(wǎng)站的二維碼海豹直播nba
  • 完整的網(wǎng)站后臺(tái)權(quán)限編碼百度手機(jī)app
  • 怎么建手機(jī)網(wǎng)站鎮(zhèn)江關(guān)鍵字優(yōu)化公司
  • 用什么給網(wǎng)站做測(cè)試競(jìng)價(jià)惡意點(diǎn)擊犯法嗎
  • 搬瓦工512m內(nèi)存wordpress北京自動(dòng)seo
  • 沙田鎮(zhèn)做網(wǎng)站湖北seo診斷
  • 工信部 網(wǎng)站要獨(dú)立ip2023b站推廣大全
  • 速成網(wǎng)站-百度怎么推廣自己的視頻
  • 給公司申請(qǐng)網(wǎng)站用自己的賬號(hào)淮安百度推廣公司
  • .jsp網(wǎng)站開(kāi)發(fā)技術(shù)疫情排行榜最新消息
  • 網(wǎng)站欄目變了怎么做跳轉(zhuǎn)競(jìng)價(jià)托管推廣公司
  • 網(wǎng)站推廣及seo方案網(wǎng)站怎么進(jìn)入
  • 網(wǎng)站建設(shè)課程設(shè)計(jì)sem托管公司
  • 做網(wǎng)站的畢業(yè)論文怎么寫(xiě)網(wǎng)絡(luò)廣告營(yíng)銷(xiāo)典型案例
  • 攝影師的網(wǎng)站有哪些深圳百度seo代理
  • 互聯(lián)網(wǎng)站備案seo關(guān)鍵詞排名優(yōu)化案例
  • 有一個(gè)做場(chǎng)景動(dòng)畫(huà)的網(wǎng)站怎么提交百度收錄
  • 蘇州知名高端網(wǎng)站建設(shè)網(wǎng)絡(luò)公司上海seo優(yōu)化外包公司
  • 做網(wǎng)站語(yǔ)言最好梅州seo
  • 一個(gè)網(wǎng)站綁定多個(gè)域名 賣(mài)域名公司網(wǎng)站免費(fèi)自建
  • 網(wǎng)站建設(shè)與維護(hù)是做什么安卓系統(tǒng)優(yōu)化軟件
  • 完美代碼網(wǎng)站google play store
  • 做視頻解析網(wǎng)站代寫(xiě)稿子的平臺(tái)
  • 懷柔高端網(wǎng)站建設(shè)win7系統(tǒng)優(yōu)化
  • 廈門(mén)it做網(wǎng)站最強(qiáng)本地推薦本地推薦
  • 保定網(wǎng)頁(yè)制作國(guó)外常用的seo站長(zhǎng)工具
  • 門(mén)業(yè)網(wǎng)站模板下載健康碼防疫核驗(yàn)一體機(jī)
  • 新手學(xué)做網(wǎng)站 cs6seo服務(wù)顧問(wèn)
  • 帝國(guó)建站系統(tǒng)b站官方推廣