首页 > 其他分享 >kafka_2.13-3.7.0 单机版安装

kafka_2.13-3.7.0 单机版安装

时间:2024-05-14 16:55:46浏览次数:14  
标签:单机版 -- kafka 3.7 apache 2.13 localhost

[root@localhost ~]# adduser kafka
[root@localhost ~]# password kafka
-bash: password: command not found
[root@localhost ~]# ls /home
jenkins  kafka  nacos
[root@localhost ~]# passwd kafka
Changing password for user kafka.
New password: 
BAD PASSWORD: The password is shorter than 8 characters
Retype new password: 
passwd: all authentication tokens updated successfully.
[root@localhost ~]# 
[kafka@localhost ~]$ wget https://dlcdn.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
--2024-04-28 17:17:00--  https://dlcdn.apache.org/kafka/3.7.0/kafka_2.13-3.7.0.tgz
Resolving dlcdn.apache.org (dlcdn.apache.org)... 151.101.2.132, 2a04:4e42::644
Connecting to dlcdn.apache.org (dlcdn.apache.org)|151.101.2.132|:443... connected.
HTTP request sent, awaiting response... 200 OK
Length: 119028138 (114M) [application/x-gzip]
Saving to: ‘kafka_2.13-3.7.0.tgz’

100%[===============================================================================================================================>] 119,028,138 3.37MB/s   in 22s    

2024-04-28 17:17:22 (5.20 MB/s) - ‘kafka_2.13-3.7.0.tgz’ saved [119028138/119028138]

[kafka@localhost ~]$ 

[kafka@localhost kafka_2.13-3.7.0]$ KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"
[kafka@localhost kafka_2.13-3.7.0]$ bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties
metaPropertiesEnsemble=MetaPropertiesEnsemble(metadataLogDir=Optional.empty, dirs={/tmp/kraft-combined-logs: EMPTY})
Formatting /tmp/kraft-combined-logs with metadata.version 3.7-IV4.
[kafka@localhost kafka_2.13-3.7.0]$ 
# 启动kafka
[kafka@localhost kafka_2.13-3.7.0]$ bin/kafka-server-start.sh config/kraft/server.properties


#防火墙配置    
iptables -A INPUT -p tcp --dport 9092 -m conntrack --ctstate NEW,ESTABLISHED -j ACCEPT
iptables -I INPUT -p tcp --dport 25 -j ACCEPT

#spring-kafka 版本需要严格与spring-context 的一致
#不然会报KafkaTemplate 无法绑定,在 Maven Repository 中通过查找spring-kafka 依赖的spring-context版本来确定 spring-kafka的版本。


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

#尝试在Windows上创建 测试生产者
D:\someusefultools\kafka\bin\windows>kafka-console-producer.bat --broker-list 192.168.1.90:9092 --topic hello_word_topic
>This is my second event!
>Windows is work!
>

$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

key-serializer=org.apache.kafka.common.serialization.StringSerializer
value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

 

标签:单机版,--,kafka,3.7,apache,2.13,localhost
From: https://www.cnblogs.com/Alex-Zeng/p/18191671

相关文章

  • [视频教程]赤壁OL单机版_80级英雄_可局域网
    [端游]赤壁OL单机版80级英雄,横刀立马,54级护卫,20种兵种,GM模式,无限元宝本教程仅限学习使用,禁止商用,一切后果与本人无关,此声明具有法律效应!!!!教程是本人亲自搭建成功的,绝对是完整可运行的,踩过的坑都给你们填上了如果你是小白也没问题,跟着教程走也是可以搭建成功的,但是一定要有耐心......
  • 麒麟 V10 一键安装 Oracle 11GR2(231017)单机版 2
    https://www.modb.pro/db/1762008192972820480安装准备1、安装好操作系统,建议安装图形化2、配置好网络3、挂载本地ISO镜像源4、上传必须软件安装包(安装基础包,补丁包:33991024、35574075、35685663、6880880)5、上传一键安装脚本:OracleShellInstall✨偷懒可以直接下载本......
  • 麒麟 V10 一键安装 Oracle 11GR2(231017)单机版
    更新记录2024-04-22调整函数顺序,优化部分逻辑目前确定不支持列表RHEL6/OEL6/CENTOS6版本不支持安装19C,21C,官方没有认证RHEL9/OEL9/CENTOS9版本不支持安装11GR2,12CR2,官方没有认证常见问题安装RAC,主节点外的ISO镜像请勿上传到/soft目录下挂载,否则会被脚本......
  • Android Emulator 34.2.13 崩溃无法启动
    AndroidEmulator在2024年4月30日发布了34.2.12版本,但是这个版本会在启动虚拟机时直接崩溃。Emulatorreleasenotes34.2.13(April30,2024)可以将AndroidEmulator降级到34.1.20或之前版本解决这个问题,官网上有降级方法和历史版本。Emulatordownloadarchives另外从......
  • SystemVerilog -- 3.7 SystemVerilog 'unique' and 'priority' if-else
    SystemVerilog'unique'and'priority'if-else条件语句用于决定是否执行语句。ifelseSystemVerilog引入了一下用于违规检查的构造。ifelseunique-ifunique0-ifpriority-ifunique-if,unique0-ifunique-if按任意顺序评估条件,并执行以下操作:当所有条件都不匹配时,报......
  • OceanBase单机版重新部署提示[ERROR] Deploy “demo“ is running. You could not dep
    执行介质里uninstall.sh脚本删除部署信息后重新安装Demo提示:[root@tidb01bin]#obddemo[ERROR]Deploy"demo"isrunning.Youcouldnotdeployanrunningcluster.Seehttps://www.oceanbase.com/product/ob-deployer/error-codes.TraceID:b18c41ba-07af-11ef-bd8f-......
  • Linux如何完全卸载OceanBase单机版
    OceanBase单机版重新部署的时候,遇到提示demoisrunning,因为之前部署的demo还在运行中,可以直接重启使用,如果想重新部署,需将之前的删除干净。本文将介绍如何删除OceanBase单机版。1.查看OB集群信息[root@tidb01bin]#obdclusterlist+-------------------------------------......
  • 启发式评估(Heuristic Evaluation)--转载 [2011.12.13 sina blog]
    启发式评估(HeuristicEvaluation) -[一架好书--读书学习的收获]2008年08月07日分类: 一架好书--读书学习的收获  版权声明:转载时请以超链接形式标明文章原始出处和作者信息及本声明http://buyantang.blogbus.com/logs/27286224.htmlUsabilityInspectionMethods,Edit......
  • 使用minikube在云服务器安装k8s单机版
    1:前置安装了docker环境2:进入minikube的官网页面,下载命令https://minikube.sigs.k8s.io/docs/start/curl-LOhttps://storage.googleapis.com/minikube/releases/latest/minikube-linux-amd64sudoinstallminikube-linux-amd64/usr/local/bin/minikubeminikubekubectl--......
  • 搭建单机版伪分布式Hadoop+Scala+spark
    搭建单机版伪分布式Hadoop+Scala+spark修改ip[root@master~]#nmcliconnectionaddifnameens32con-nameens32autoconnectyesipv4.methodmanualipv4.gateway192.168.130.2ipv4.addresses192.168.130.102/24ipv4.dns114.114.114.114[root@master~]#nmcliconu......