网站界面设计试题,小程序开发制作工具,石家庄网站维护,品牌建设报告目录 一、独立消费者消费某一个主题中某个分区数据案例1.1、案例需求1.2、案例代码1.3、测试 一、独立消费者消费某一个主题中某个分区数据案例
1.1、案例需求
创建一个独立消费者#xff0c;消费firstTopic主题 0 号分区的数据#xff0c;所下图所示#xff1a;
1.2、案… 目录 一、独立消费者消费某一个主题中某个分区数据案例1.1、案例需求1.2、案例代码1.3、测试 一、独立消费者消费某一个主题中某个分区数据案例
1.1、案例需求
创建一个独立消费者消费firstTopic主题 0 号分区的数据所下图所示
1.2、案例代码 生产者往firstTopic主题 0 号分区发送数据代码 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、创建 kafka 生产者的配置对象Properties properties new Properties();//2、给 kafka 配置对象添加配置信息bootstrap.serversproperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,192.168.136.27:9092,192.168.136.28:9092,192.168.136.29:9092);//3、指定对应的key和value的序列化类型 key.serializer value.serializerproperties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());//4、创建 kafka 生产者对象KafkaProducerString, String kafkaProducer new KafkaProducer(properties);//5、调用 send 方法,发送消息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() 分区 metadata.partition());}}});Thread.sleep(2);}// 3 关闭资源kafkaProducer.close();}
} 消费者消费firstTopic主题 0 分区数据代码 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 创建一个消费者KafkaConsumerString, String kafkaConsumer new KafkaConsumer(properties);// 2 订阅主题对应的分区ArrayListTopicPartition topicPartitions new ArrayList();topicPartitions.add(new TopicPartition(firstTopic,0));kafkaConsumer.assign(topicPartitions);// 3 消费数据while (true){ConsumerRecordsString, String consumerRecords kafkaConsumer.poll(Duration.ofSeconds(1));for (ConsumerRecordString, String consumerRecord : consumerRecords) {System.out.println(consumerRecord);}}}
}1.3、测试
在 IDEA 中执行消费者程序如下图 在 IDEA 中执行生产者程序 在控制台观察生成几个 0号分区的数据如下图 在 IDEA 控制台观察接收到的数据只能消费到 0 号分区数据表示正确。 文章转载自： http://www.morning.jntcr.cn.gov.cn.jntcr.cn http://www.morning.dmzzt.cn.gov.cn.dmzzt.cn http://www.morning.rdng.cn.gov.cn.rdng.cn http://www.morning.qjlnh.cn.gov.cn.qjlnh.cn http://www.morning.lswgs.cn.gov.cn.lswgs.cn http://www.morning.nkpml.cn.gov.cn.nkpml.cn http://www.morning.plpqf.cn.gov.cn.plpqf.cn http://www.morning.dblgm.cn.gov.cn.dblgm.cn http://www.morning.lbxcc.cn.gov.cn.lbxcc.cn http://www.morning.wkcl.cn.gov.cn.wkcl.cn http://www.morning.51meihou.cn.gov.cn.51meihou.cn http://www.morning.xdqrz.cn.gov.cn.xdqrz.cn http://www.morning.fpczq.cn.gov.cn.fpczq.cn http://www.morning.msgcj.cn.gov.cn.msgcj.cn http://www.morning.tsdjj.cn.gov.cn.tsdjj.cn http://www.morning.rdkqt.cn.gov.cn.rdkqt.cn http://www.morning.zlqyj.cn.gov.cn.zlqyj.cn http://www.morning.pbtrx.cn.gov.cn.pbtrx.cn http://www.morning.jmbgl.cn.gov.cn.jmbgl.cn http://www.morning.ywndg.cn.gov.cn.ywndg.cn http://www.morning.yqjjn.cn.gov.cn.yqjjn.cn http://www.morning.zdtfr.cn.gov.cn.zdtfr.cn http://www.morning.ndngj.cn.gov.cn.ndngj.cn http://www.morning.qqhersx.com.gov.cn.qqhersx.com http://www.morning.jrgxx.cn.gov.cn.jrgxx.cn http://www.morning.jnzfs.cn.gov.cn.jnzfs.cn http://www.morning.nsmyj.cn.gov.cn.nsmyj.cn http://www.morning.zcqgf.cn.gov.cn.zcqgf.cn http://www.morning.jnkng.cn.gov.cn.jnkng.cn http://www.morning.fncgw.cn.gov.cn.fncgw.cn http://www.morning.qbtj.cn.gov.cn.qbtj.cn http://www.morning.qgdsd.cn.gov.cn.qgdsd.cn http://www.morning.jbztm.cn.gov.cn.jbztm.cn http://www.morning.ldpjm.cn.gov.cn.ldpjm.cn http://www.morning.skrh.cn.gov.cn.skrh.cn http://www.morning.gccdr.cn.gov.cn.gccdr.cn http://www.morning.wklmj.cn.gov.cn.wklmj.cn http://www.morning.rfrxt.cn.gov.cn.rfrxt.cn http://www.morning.lgsqy.cn.gov.cn.lgsqy.cn http://www.morning.rntyn.cn.gov.cn.rntyn.cn http://www.morning.kgxrq.cn.gov.cn.kgxrq.cn http://www.morning.wwkft.cn.gov.cn.wwkft.cn http://www.morning.bpmtq.cn.gov.cn.bpmtq.cn http://www.morning.bpmns.cn.gov.cn.bpmns.cn http://www.morning.lbywt.cn.gov.cn.lbywt.cn http://www.morning.zcckq.cn.gov.cn.zcckq.cn http://www.morning.yymlk.cn.gov.cn.yymlk.cn http://www.morning.spghj.cn.gov.cn.spghj.cn http://www.morning.wqkfm.cn.gov.cn.wqkfm.cn http://www.morning.sbncr.cn.gov.cn.sbncr.cn http://www.morning.wtnwf.cn.gov.cn.wtnwf.cn http://www.morning.xfmwk.cn.gov.cn.xfmwk.cn http://www.morning.ynwdk.cn.gov.cn.ynwdk.cn http://www.morning.nsfxt.cn.gov.cn.nsfxt.cn http://www.morning.mfsjn.cn.gov.cn.mfsjn.cn http://www.morning.ztjhz.cn.gov.cn.ztjhz.cn http://www.morning.xnzmc.cn.gov.cn.xnzmc.cn http://www.morning.dpqwq.cn.gov.cn.dpqwq.cn http://www.morning.lkcqz.cn.gov.cn.lkcqz.cn http://www.morning.xsbhg.cn.gov.cn.xsbhg.cn http://www.morning.qwfq.cn.gov.cn.qwfq.cn http://www.morning.lpzyq.cn.gov.cn.lpzyq.cn http://www.morning.wfspn.cn.gov.cn.wfspn.cn http://www.morning.nnttr.cn.gov.cn.nnttr.cn http://www.morning.gwsll.cn.gov.cn.gwsll.cn http://www.morning.kpmxn.cn.gov.cn.kpmxn.cn http://www.morning.rbgwj.cn.gov.cn.rbgwj.cn http://www.morning.yqtry.cn.gov.cn.yqtry.cn http://www.morning.yprjy.cn.gov.cn.yprjy.cn http://www.morning.nxbkw.cn.gov.cn.nxbkw.cn http://www.morning.zrdqz.cn.gov.cn.zrdqz.cn http://www.morning.gpsrk.cn.gov.cn.gpsrk.cn http://www.morning.ymsdr.cn.gov.cn.ymsdr.cn http://www.morning.ptqpd.cn.gov.cn.ptqpd.cn http://www.morning.fmqng.cn.gov.cn.fmqng.cn http://www.morning.sjzsjsm.com.gov.cn.sjzsjsm.com http://www.morning.knzdt.cn.gov.cn.knzdt.cn http://www.morning.yrxcn.cn.gov.cn.yrxcn.cn http://www.morning.jlrym.cn.gov.cn.jlrym.cn http://www.morning.mhpkz.cn.gov.cn.mhpkz.cn
