首页 > 其他分享 >Kafka简单使用

Kafka简单使用

时间:2023-05-20 10:56:55浏览次数:62  
标签:bin -- 使用 server topic 简单 kafka Kafka localhost

启动zookeeper

> bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

启动Kafka Server

> bin/kafka-server-start.sh config/server.properties

Topic相关

创建Topic

新版命令:
> bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic [topic-name]

查看所有topic列表

> bin/kafka-topics.sh --list --bootstrap-server localhost:9092

查看某个topic的信息

> bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic [topic-name]

修改某个topic的partition个数(分区数只能增不能减)

> bin/kafka-topics.sh --bootstrap-server localhost:2181 --alter --topic [topic-name] --partitions [new-partitions-count]
eg: > bin/kafka-topics.sh --bootstrap-server localhost:2181 --alter --topic topic-test --partitions 10

Producer相关

Producer生产消息

> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic [topic-name]

Consumer相关

查看所有消费者组

> bin/kafka-consumer-groups --bootstrap-server localhost:9092 --list

查看指定group(group01)的消费情况

> bin/kafka-consumer-groups --describe --group group01 --bootstrap-server localhost:9092

Consumer消费消息

> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic [topic-name]

标签:bin,--,使用,server,topic,简单,kafka,Kafka,localhost
From: https://www.cnblogs.com/lsh-admin/p/17416894.html

相关文章

  • 使用ln命令在Linux系统中创建连接文件
    在Linux中ln命令用来为文件创建连接,连接类型分为硬连接(HardLink)和符号连接(SymbolicLink)两种,默认的连接类型是硬连接。如果要创建符号连接必须使用"-s"选项。关于软硬连接解释硬连接硬连接是指通过索引节点来进行连接。在Linux的文件系统中,保存在磁盘分区中的文件不管是......
  • 【vue】div标签和template标签使用区别
       ......
  • ChatGPT 推出 iOS 应用,支持语音输入,使用体验如何?
    最近,OpenAI宣布推出官方iOS应用,允许用户随时随地访问其高人气AI聊天机器人,此举也打破了近几个月内苹果AppStore上充斥似是而非的山寨服务的窘境。该应用程序是ChatGPT的首个官方移动应用程序。ChatGPT软件程序在去年推出后迅速获得了超过1亿用户,这也让技术行业火速......
  • 使用 MRKL 系统跨越神经符号鸿沟
    本文展示了自然语言处理的下一步发展——模块化推理、知识和语言(theModularReasoning,KnowledgeandLanguage,简称为MRKL)系统以及LangChain和SemanticKernel的实现。MRKL系统包括一个或多个语言模型,并通过外部知识源和符号推理专家来增强它们,这些专家可以处理神经模型无法处......
  • 如何在代码开发中便捷使用 ChatGPT 协助开发
    在五一节前后,抽空测试了下网上推荐的开发环境和开发插件,在这里推荐给前后端代码开发的同胞们。方法一:IDEA安装插件bito习惯使用IDEA开发代码的同胞,可以尝试直接在IDEA中安装插件bito,注意操作过程中需要注册账号并登录。如下。安装成功后在右侧栏可以看到快捷导航图标,如下。......
  • 信息熵、交叉熵、KL散度公式的简单理解
    整理:我不爱机器学习1信息量信息量是对信息的度量,就跟时间的度量是秒一样,考虑一个离散的随机变量x的时候,当观察到的这个变量的一个具体值的时候,我们接收到了多少信息呢?例如听到太阳从东方升起,这样信息对于我们来说价值不大,因为这是一个必然事件,所以这个信息传递给我们的信息量为......
  • flutter系列之:使用AnimationController来控制动画效果
    目录简介构建一个要动画的widget让图像动起来总结简介之前我们提到了flutter提供了比较简单好用的AnimatedContainer和SlideTransition来进行一些简单的动画效果,但是要完全实现自定义的复杂的动画效果,还是要使用AnimationController。今天我们来尝试使用AnimationController来实现......
  • 使用Python爬取给定网页的所有链接(附完整代码)
    此脚本从给定的网页中检索所有链接,并将其保存为txt文件。(文末有完整源码)这是一个简单的网络爬虫示例,使用了requests库来发送HTTP请求并获取网页内容,使用BeautifulSoup库来解析网页内容。代码解释如下:1.导入所需的库导入requests库并将其重命名为rq,用于发送HTTP请求和获......
  • 使用ssm框架出现数据库连接问题
    java.sql.SQLException:Accessdeniedforuser'jdbc:mysql://localhost:3306/oa?useSSL=false&allo'@'localhost'(usingpassword:YES)或者是PublicKeyRetrievalisnotallowed查阅资料发现当publicKeyRetrievalisnotAllowed错误解决或依然会出现数据连接失败问......
  • 【数论】Rust使用Miller-Rabin primality test判别素数
    题目地址https://ac.nowcoder.com/acm/contest/57677/A代码usestd::io::{self,BufRead,Write};fnis_prime_triival(n:i128)->bool{ifn<=1{returnfalse;}ifn==2{returntrue;}ifn%2==0{retur......