首页 > 编程语言 >java——spring boot集成kafka——单节点示例

java——spring boot集成kafka——单节点示例

时间:2023-03-25 18:33:55浏览次数:41  
标签:java 示例 -- spring kafka topic 消息 172.16 test

首先安装一个zk。然后再安装kafka:

 

 

 

执⾏以下命令创建名为“test”的topic,这个topic只有⼀个partition,并且备份因⼦也设置为1:

 

然后在kafka节点下,执行如下命令:

 

./kafka-topics.sh --create --zookeeper 172.16.253.35:2181 --replicationfactor 1 --partitions 1 --topic test

 

 

含义:副本为1;分区为1;主题为test;

(1)、replicationfactor——副本;

(2)、partitions——分区;

(3)、topic——主题;

 

-------------------------------------------------------------------------------------------------------------------------------------------------

 

然后,查看当前kafka内有哪些topic,执行如下命令:

 

./kafka-topics.sh --list --zookeeper 172.16.253.35:2181

 

 

======================================================================================================

 

 

发送消息

 

kafka⾃带了⼀个producer命令客户端,可以从本地⽂件中读取内容,或者我们也可以以命令⾏中直接输⼊内容,并将这些内容以消息的形式发送到kafka集群中。

 

在默认情况下,每⼀个⾏会被当做成⼀个独⽴的消息。使⽤kafka的发送消息的客户端,指定发送到的kafka服务器地址和topic

 

 ./kafka-console-producer.sh --broker-list 172.16.253.38:9092 --topic test

 

 

 =============================================================================================================================

 

 

 

 消费消息

 

 

对于consumer, kafka同样也携带了⼀个命令⾏客户端,会将获取到内容在命令中进⾏输出, 默认是消费最新的消息。

 

使⽤kafka的消费者消息的客户端,从指定kafka服务器的指定topic中消费消息

 

 

------------------------------------------------------------------------------------------------------------------------------------------------------------------

 

 ⽅式⼀:从最后⼀条消息的偏移量+1开始消费

 

 

  ./kafka-console-consumer.sh --bootstrap-server 172.16.253.38:9092 --topic test

 

 

 ----------------------------------------------------------------------------------------------------------------------------------------------------------------------

 

 

 ⽅式⼆:从头开始消费

 

 

  ./kafka-console-consumer.sh --bootstrap-server 172.16.253.38:9092 --from-beginning --topic test

 

 

 

 ===============================================================================================================

 

 

 

⼏个注意点:


(1)、消息会被存储
(2)、消息是顺序存储
(3)、消息是有偏移量的
(4)、消费时可以指明偏移量进⾏消费

 

 

 

=====================================================================================================

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 


标签:java,示例,--,spring,kafka,topic,消息,172.16,test
From: https://www.cnblogs.com/xiaobaibailongma/p/17255304.html

相关文章

  • SpringBoot集成SpringBootAdmin实现监控
    效果展示客户端maven引用<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifa......
  • Java进阶基础知识点(包及final关键字、常量)
    一:包的概述包就是文件夹,用来管理各种不同功能的Java类,方便后期代码维护。包的命名规则:公司域名的反写+包的作用,需要全部英文小写,见名知意。例如;com.51cto.domain.student.......
  • Spring
    1.简介Spring是一个免费的开源框架(容器)Spring是一个轻量级、非入侵式的框架控制反转(IOC),面向切面(AOP)编程支持事务处理,对框架整合也支持2.组成-七大模块3.IOC理论推......
  • SpringMVC快速入门与详解
    一、SpringMVC简介1.概念 SpringMVC是一种基于Java的实现MVC设计模式的Web框架,该框架通过将Web应用程序划分为模型、视图和控制器来简化Web应用程序的开发......
  • SpringBoot集成SpringBootAdmin实现监控
    效果展示客户端maven引用<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artif......
  • JavaSE
    前言字节流和字符流体系相同,仅操作的数据类型不同。节点流和过滤流的关系,是装饰者模式的体现。转换流,是适配器模式的体现。I/O对磁盘文件的读写,针对的是File类。......
  • JavaSE
    File:用于代表磁盘中的一个文件或文件夹(未必真实存在),提供操作文件本身的方法。1、常用属性路径分隔符:;pathSeparator``pathSeparatorChar`名称分隔符:\Separ......
  • Java基础知识流程与示例
    一、Java知识流程Java语言特点和发展历史数据类型、变量和常量运算符和表达式控制语句(if、switch、for、while等)数组和字符串面向对象编程(类和对象、继承、封装、多......
  • 使用Docker 一键部署SpringBoot和SpringCloud项目
    Docker是一个非常流行的容器化技术,可以方便地将应用程序和服务打包成容器并运行在不同的环境中。在本篇博客中,我将向您展示如何使用Docker一键部署SpringBoot和SpringCloud......
  • 【华为OD机试真题2023 JAVA】Linux发行版的数量
    Linux发行版的数量知识点DFS搜索BFS搜索并查集时间限制:1s空间限制:256MB限定语言:不限题目描述:Linux操作系统有多个发行版,distrowatch.com提供了各个发行版的资料。这些发......