首页 > 其他分享 >kafka常用命令

kafka常用命令

时间:2023-12-28 10:45:26浏览次数:39  
标签:bin bat -- kafka windows 常用命令 server

Windows

 1.启动zookeeper,kafka高版本已经集成 zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
​
 2.启动kafka服务器
bin\windows\kafka-server-start.bat config\server.properties
​
 3.创建topic
bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic singleTopic
​
 4.查看topics
bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --list
​
 5.查看topic 详细信息
bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic singleTopic
​
 6.删除topic
bin\windows\kafka-topics.bat --delete --bootstrap-server localhost:9092 --topic singleTopic
​
 7.关闭 kafka 服务器
bin\windows\kafka-server-stop.bat

标签:bin,bat,--,kafka,windows,常用命令,server
From: https://www.cnblogs.com/xiaolibiji/p/17932211.html

相关文章

  • Kafka 再均衡详解:实现消费者组的负载均衡和故障转移(十二)
    在Kafka中,再均衡(Rebalancing)是指在消费者组内部发生变化时,Kafka会重新分配分区给消费者,以实现负载均衡和故障转移的目的。再均衡是Kafka实现高可用性和可扩展性的重要机制之一。再均衡的场景消费者加入、消费者退出和分区变化等情况。消费者加入:当新的消费者加入消费者组......
  • Kafka与ClickHouse开发与应用_tyt2023
    本实验基于MRS环境,Kafka部分主要介绍kafka命令行脚本的基本使用规范,以及通过介绍一个电商数据实时分析的场景将Kafka和SparkStreaming进行组合,帮助大家更好地掌握实际项目的开发流程。ClickHouse部分主要介绍常见的业务操作,代码样例中所涉及的SQL操作主要包括创建数据库、创建表......
  • Linux的常用命令
    1.文件与目录的管理命令: 命令细节:ls : -l 展示详细信息,-a 展示隐藏文件(Linux下 . 开头的为隐藏文件) pwd:查看当前所在位置的绝对路径 cd:参数为绝对路径或者相对路径, cd后无参数则表示回到主目录 touch:表示新建文件 mkdir:创建目录 rm :删除表示直接......
  • kafka安装
    单节点kafka安装#!/bin/bash###############################################################FileName:install_kafka.sh#Version:V1.0#Author:junwang#Organization:#CreatedTime:2021-04-1417:12:54#Description:###################################......
  • kafka 自定义开发Sink Connector组件(兼容mysql和oracle)
    1.情景展示目前,市场上已有不少能从kafka消费数据的插件,如:io.confluent.connect.jdbc.JdbcSinkConnector,但这个组件有个致命的问题是,只能同步字符串类型。具体意思是:源库源表的日期类型字段,往目标库目标表插入数据的时候,只能是字符串类型,无法自动将其转成日期类型。这样一来的......
  • QT 中配置 64位kafka ,c++
    在MSYS2下,执行$pacman-Smingw32/mingw-w64-i686-librdkafkamingw64/mingw-w64-x86_64-librdkafka即可获得二进制库、头文件和动态链接库。文件路径实例,D:\msys64\mingw64下找文件即可:D:\msys64\mingw64\lib\librdkafka++.dll.a 在工程文件中创建文件夹thirdparty/librdkaf......
  • kafka 实战-记一次生产环境broker may not available
    1故障背景10:09:34.948ifpo.apache.kafka.clients.Networkclient748[ProducerclientId=producer-1]Connectiontonode0(10.x.x.x:9093)couldnotbeestablished.Brokermaynotbeavailable.故障细节生产kafka服务端集群全部宕机,但车端还在往我的数据网关服务上......
  • RabbitMQ vs Kafka:正面交锋!
    介绍作为一名有着大量微服务系统处理经验的软件架构师,我经常遇到一个不断重复的问题:“我应该使用RabbitMQ还是Kafka?”出于某种原因,许多开发人员认为这些技术是可以互换的。虽然在某些情况下确实如此,但RabbitMQ还是Kafka之间存在根本上的差异。因此,不同的场景需要不同的,选择......
  • linux常用命令(笔记)
    1、telnet进去后怎么退出:telnet10.102.5.11922查看ip,端口通讯状况退出的话:Ctrl+]然后输入q退出,如下图:2、linux下查看tomcat版本curl172.16.45.231:8080|grep"ApacheTomcat"curlIP:端口|grep"ApacheTomcat"3、关于CPU命令——查看CPU型号cat/......
  • Apache Geode‘s Integration with Apache Kafka: Building HighThroughput, LowLaten
    1.背景介绍在当今的大数据时代,高性能、高吞吐量和低延迟的数据处理能力已经成为企业和组织的核心需求。ApacheGeode和ApacheKafka都是开源社区提供的强大工具,它们各自擅长于不同的数据处理场景。Geode是一个高性能的分布式缓存和计算引擎,它可以处理大量数据并提供低延迟的访......