HelloKafka入门 helloKafka

HelloKafka

一、启动好zookeeper
二、启动好kafka
三、代码类

一、启动好zookeeper

二、启动好kafka

三、代码类

HelloKafkaProducer.java

import cn.enjoyedu.config.BusiConst;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;import java.util.Properties;/*** 类说明：kafka生产者*/
public class HelloKafkaProducer {public static void main(String[] args) {Properties properties=new Properties();properties.put("bootstrap.servers","127.0.0.1:9092");properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");KafkaProducer<String,String> producer=new KafkaProducer<String, String>(properties);ProducerRecord<String,String> record;//TODO 发送4条消息try {for (int i = 0; i < 4; i++) {record=new ProducerRecord<>(BusiConst.HELLO_TOPIC,"1","lison");producer.send(record);//发送并忘记System.out.println(i+"message is send");;}} catch (Exception e) {e.printStackTrace();} finally {producer.close();}}}

HelloKafkaConsumer.java

import cn.enjoyedu.config.BusiConst;
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.serialization.StringDeserializer;
import org.apache.kafka.common.utils.Time;import java.time.Duration;
import java.util.Collections;
import java.util.Properties;/*** 类说明：kafka消费者*/
public class HelloKafkaConsumer {public static void main(String[] args) {// 消费者三个属性必须制定(broker 地址清单、key和value的反序列化器)Properties properties=new Properties();properties.put("bootstrap.servers","127.0.0.1:9092");properties.put("key.deserializer",StringDeserializer.class);properties.put("value.deserializer",StringDeserializer.class);//TODO 群组并非完全必须properties.put(ConsumerConfig.GROUP_ID_CONFIG,"test1");KafkaConsumer<String,String> consumer=new KafkaConsumer<String, String>(properties);try {// 消费者订阅主题(可以多个)consumer.subscribe(Collections.singletonList(BusiConst.HELLO_TOPIC));while (true){//拉取ConsumerRecords<String,String> records=consumer.poll(Duration.ofMillis(500));for (ConsumerRecord<String,String> record:records) {System.out.println(String.format("topic:%s,分区:%d,偏移量:%d,"+"key:%s,value:%s",record.topic(),record.partition(),record.offset(),record.key(),record.value()));}}} finally {consumer.close();}}}

HelloKafka入门 helloKafka相关推荐

Kafka操作之kafka-topics
目录简介操作创建 --create 列表 --list 详细信息 --describe 删除 --delete 修改 --alter 基本参数简介 kafka-topics.bat 脚本负责主 ...
消息中间件 --- Kafka快速入门
消息中间件 --- Kafka 快速入门消息中间件:https://blog.51cto.com/u_9291927/category33 GitHub: GitHub - scorpiostudi ...
用Construct 2制作入门小游戏~
今天在软导课上了解到了Construct 2这个神器,本零基础菜鸟决定尝试做一个简单的小游戏(实际上是入门的教程啊= = 首先呢,肯定是到官网下载软件啊,点击我下载~ 等安装完毕后我便按照新手教程开始 ...
Docker入门六部曲——Swarm
原文链接:http://www.dubby.cn/detail.html?id=8738 准备工作安装Docker(版本最低1.13). 安装好Docker Compose,上一篇文章介绍过的. 安 ...
Docker入门六部曲——Stack
原文链接:http://www.dubby.cn/detail.html?id=8739 准备知识安装Docker(版本最低1.13). 阅读完Docker入门六部曲--Swarm,并且完成其中介绍 ...
Docker入门六部曲——服务
原文链接:http://www.dubby.cn/detail.html?id=8735 准备已经安装好Docker 1.13或者以上的版本. 安装好Docker Compose.如果你是用的是Do ...
【springboot】入门
简介: springBoot是spring团队为了整合spring全家桶中的系列框架做研究出来的一个轻量级框架.随着spring4.0推出而推出,springBoot可以説是J2SEE的一站式解决方案 ...
SpringBoot (一) ：入门篇 Hello World
什么是SpringBoot Spring Boot是由Pivotal团队提供的全新框架,其设计目的是用来简化新Spring应用的初始搭建以及开发过程.该框架使用了特定的方式来进行配置,从而使开发人员不 ...
入门指南目录页 -PaddlePaddle 飞桨入门指南 FAQ合集-深度学习问题
入门指南目录页 -PaddlePaddle 飞桨入门指南 FAQ合集 GT_Zhang关注 0.1012019.08.01 18:43:34字数 1,874阅读 795 Hi,欢迎各位来自Paddl ...

HelloKafka入门 helloKafka

HelloKafka

一、启动好zookeeper

二、启动好kafka

三、代码类

HelloKafka入门 helloKafka相关推荐

最新文章

热门文章