首页 > 其他分享 >kafka3.x 简单使用

kafka3.x 简单使用

时间:2023-09-11 15:22:05浏览次数:47  
标签:bin quickstart 简单 -- kafka3 kafka topic 使用 server

*** 保证kafka和zookeeper已经在linux上进行了安装,目录需要改为自己的目录

 

*** kafka2.8之后引入了kraft机制,不用zookeeper也能启动

参数介绍

 --create 创建一个topic
 --topic  [your_topic_name] 创建的topic的信息
 --describe 描述信息
 --bootstrap-server [host_url] 指定的服务器地址
 --from-beginning 表示从什么地方开始获取信息

开启zookeeper

 /mydata/zookeeper/apache-zookeeper-3.6.3-bin/bin/zkServer.sh start

开启kafka

 /mydata/kafka/kafka_2.12-3.5.0/bin/kafka-server-start.sh /mydata/kafka/kafka_2.12-3.5.0/config/server.properties

创建一个topic

 $ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

显示使用信息和分区计数信息

 $ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092
 Topic: quickstart-events        TopicId: NPmZHyhbR9y00wMglMH2sg PartitionCount: 1       ReplicationFactor: 1    Configs:
     Topic: quickstart-events Partition: 0    Leader: 0   Replicas: 0 Isr: 0

开启生产者,向其中写入消息

 & bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
 >This is my first event
 >This is my second event

开启消费者,读取消息

 $ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
 This is my first event
 This is my second event

 

 

标签:bin,quickstart,简单,--,kafka3,kafka,topic,使用,server
From: https://www.cnblogs.com/huoziqi/p/17693638.html

相关文章

  • 02使用vivado和Modelsim进行仿真
    软件版本:vitis2021.1(vivado2021.1)操作系统:WIN1064bit硬件平台:适用AMD-XILINXA7/K7/Z7/ZU/KU系列FPGA登录"米联客"SOC|SOC社区-www.uisrc.com视频课程、答疑解惑!1概述仿真是每个初学者必须学会的一项技能,因为FPGA程序编译时间往往很长,所以对程序进行仿真就成为了校验程序......
  • Python中list是什么意思?如何创建使用?
    list代表列表,它是Python中的一种数据类型,与其他编程语言的数组有相似的特点,但是它有着更为强大的功能,接下来我们一起来看看具体的内容介绍。Python中的list是列表,是一种数据类型。序列是Python中最基本的数据结构。序列中的每个元素都分配一个数字-它的位置,或索引,第一......
  • 如何使用 Idea 远程调试 Java 代码
    ​服务端配置首先,我们要让要让远程服务器支持远程调试功能,在项目启动项上追加特定的JVM参数即可,参数如下:晚于JDK1.4.X版本1-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=4001JDK1.4.X版本1-Xdebug-Xrunjdwp......
  • Docker Desktop 安装使用教程
    一、前言作为开发人员,在日常开发中,我们需要在本地去启动一些服务,如:redis、MySQL等,就需要去下载这些在本地去启动,操作较为繁琐。此时,我们可以使用DockerDesktop,来搭建我们需要的服务,直接在容器中去启动即可。二、下载DockerDesktopdocker官网:三、安装DockerDesktop1、下载并......
  • 使用RestTemplate发送POST请求
    一、添加RestTemplate依赖在使用RestTemplate之前,需要向项目中添加相应的依赖。在Maven项目中,可以在pom.xml文件中添加以下依赖:<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>在Gradle项......
  • 工业场景中的NAT网关:使用功能与应用场景
    在网络领域,网络地址转换(NAT)网关是一种重要的技术设备,它的主要作用是解决网络地址和端口转换的问题,从而让内部网络中的设备能够与外部网络进行通信。它通过将内部网络中的IP地址和端口号映射到外部网络的IP地址和端口号,实现地址空间的转换。这样,内部网络的设备可以使用有限的内部地......
  • 使用Python开发一个ICP备案查询接口
    使用Python开发一个ICP备案查询接口实现目标支持通过域名、APP名称、快应用名称、小程序名称来查询对应的备案信息支持通过公司主体名称来查询所有备案信息,并支持分页查询支持通过备案号来查询备案信息构建一个高性能的模块基于模块构建一个高性能的本地化Api,并提供更人性......
  • 技术文档 | 免下载、0配置、多任务并发,在Docker Image中使用OpenSCA
    想跳过下载步骤快速使用OpenSCA检测代码风险?想实现多个项目并发扫描?在DockerImage中使用OpenSCA即可轻松实现。一起来looklook目的方便用户使用最新版本的 OpenSCA-cli保证环境的一致性,消除不同操作系统对结果的影响可以方便在本地维护不同版本的 OpenSCA-cli方便在特定情况下......
  • java文件传输简单方法
    java文件传输简单方法假设现在已经打包了一个文件(1233444333),要将这个文件传输给另一方:importjava.io.*;publicclassF_PasswordUnPassword{publicstaticvoidmain(String[]args)throwsException{ByteArrayOutputStreamarrOut=newByteArrayOutputStream();DataOutputStre......
  • 使用Spring Boot构建高性能的Java后端应用
    引言在现代应用程序开发中,构建高性能的后端服务是至关重要的。SpringBoot是一种流行的Java框架,可以帮助开发者快速构建高性能的后端应用。本博客将深入探讨如何使用SpringBoot来构建高性能的Java后端应用,并提供实际的代码示例。SpringBoot简介SpringBoot是SpringFramework......