【kafka】 windows平台搭建及使用

一、安装

  • kafka 需要java环境;
  • kafka 最新版本内置了 zookeeper,所以不需要安装zookeeper;
  • 下载kafka最新版本,因为下载的是tgz文件,所以不需要安装,解压到相应的地方就可以了。下载地址:http://kafka.apache.org/downloads(我使用的版本:kafka_2.11-1.1.0)
  • bin 目录下放的是启动kafka的文件,conf目录下放的是kafka的各种配置文件。

  总结:至此kafka在windows平台上的搭建完成了。

二、使用:

    简单测试,查看是否ok。
    PS:zookeeper默认端口:2181;生产者默认端口:9092
    总结:
        简单测试一共五步:
        1.启动zookeeper
        2.启动kafka
        3.创建主题topic
        4.启动消费者 customer
        5.启动生产者 producer
        

1.启动zookeeper

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2.启动kafka

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

3.创建主题topic,并查看

创建命令:
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic wzq
查看命令:
bin\windows\kafka-topics.bat --list --zookeeper localhost:2181


4.启动消费者 customer

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic wzq --from-beginning

5.启动生产者 producer

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic wzq

PS:有五个黑窗口 1.zookeeper服务(不可关闭) 2.kafka服务(不可关闭) 3.创建主题(可关闭) 4.消费者(不可关闭) 5.生产者(不可关闭)。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/273689.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Unix/Linux环境C编程入门教程(16) LinuxMint CCPP开发环境搭建

1.Linux Mint由Linux Mint Team团队于2006年开始发行,是一份基于Debian和Ubuntu的Linux发行版。其目标是提供一种更完整的即刻可用体验,这包括提供浏览器插件、多媒体编解码器、对DVD播放的支持、Java和其他组件,它也增加了一套定制桌面及各种…

@TableLogic注解表示逻辑删除

TableLogic注解表示逻辑删除 效果:在字段上加上这个注解再执行BaseMapper的删除方法时,删除方法会变成修改 场景: 1.实体类中属性加上TableLogic, TableLogic private Integer dataStatus; 2.调用BaseMapper的deleteById(id)或…

图片上传至本地

1.配置文件 bootstrap.yml file:path:httpResURL: http://122.246.1.148:19086SAVE_PATH: /data/imagesresURI: /wzq/ 2.文件工具类 import cn.hutool.core.io.FileUtil; import com.vinsuan.park.platform.biz.FilePathConfig; import lombok.AllArgsConstructor; import lo…

html调用静态json例子

html调用静态json例子 1.json {"current": 2,"result": "success" } 1.html <!doctype html> <html> <head> <meta charset"utf-8"> <title></title> <script src"http://code.jquery.co…

Extjs发票管理系统

技术特点&#xff1a;Extjs框架&#xff0c;三层架构&#xff0c;Ajax,json 1.仿office2007菜单.介面美观大方,可动态更改皮肤保存至cookie。 2,json数据源与实体类的相互转换. 3.可下载桌面版登录方式,统计在线人数. 4, chm操作手册,方便操作人员熟悉. 功能描述&#xff1a; 1…

jQuery调用WebService返回JSON数据

相信大家都比较了解JSON格式的数据对于ajax的方便&#xff0c;不了解的可以从网上找一下这方面的资料来看一下&#xff0c;这里就不多说了&#xff0c;不清楚的可以在网上查一下&#xff0c;这里只说一下因为参数设置不当引起的取不到返回值的问题。 在用jQuery调用WebService的…

Docker---问题1:bash: vi: command not found/bash: vim: command not found

在使用docker时&#xff0c;有时候我们需要编辑配置文件&#xff0c;需要使用vim或者vi命令&#xff0c;发现&#xff1a; root64801a03b121:/etc/nginx/conf.d# vi default.conf bash: vi: command not found root64801a03b121:/etc/nginx/conf.d# vim default.conf bash: …

C# 获取配置文件节点值

<?xml version"1.0" encoding"utf-8" ?><configuration> <appSettings> <add key"ManagerName" value"XXX" /> </appSettings> <connectionStrings> <add name"DataBase"…

WHENEVER SQLERROR EXIT SQL.SQLCODE

1.SQL>WHENEVER SQLERROR EXIT SQL.SQLCODE出现错误后终止SQL*Plus运行。2.SQL>WHENEVER SQLERROR SQL.SQLCODE EXIT ROLLBACK 除了之前的含义&#xff0c;还包括让SQL*Plus在推出之前把所有还没提交的变化回滚处理。转载于:https://www.cnblogs.com/nuaa/p/3828473.html…

IDEA 快捷键终极大全

一、自动代码 常用的有fori/sout/psvmTab即可生成循环、System.out、main方法等boilerplate样板代码 。 例如要输入for(User user : users)只需输入user.forTab &#xff1b; 再比如&#xff0c;要输入Date birthday user.getBirthday()只需输入user.getBirthday().varTab即…

数组中只出现一次的数字

题目&#xff1a;一个整型数组里&#xff0c;除了两个数字以外&#xff0c;其他数字都出现了两次&#xff0c;请写程序找到这两个只出现一次的数字。要求&#xff1a;时间复杂度为O(n),空间复杂度为O(1). 分析&#xff1a;看到这题&#xff0c;首先要明白&#xff0c;这是求两个…

iOS工作笔记之NSClassFromString

id myObj [[NSClassFromString("MySpecialClass") alloc] init]; 和 id myObj [[MySpecialClass alloc] init]; 是一样的。但是&#xff0c;如果你的程序中并不存在MySpecialClass这个类&#xff0c;下面的写法会出错&#xff0c;而上面的写法只是返回一个空对象而…

Maven 使用bat批量清除本地仓库的lastUpdated文件

echo off set REPOSITORY_PATHC:\Users\Administrator\.m2\repository rem 正在搜索... for /f "delims" %%i in (dir /b /s "%REPOSITORY_PATH%\*lastUpdated*") do ( del /s /q %%i ) rem 搜索完毕 pause 新建一个文件txt文件&#xff0c;把.txt后缀…

“ddl”有一个无效 SelectedValue,因为它不在项目列表中。

“ddl_ekt”有一个无效 SelectedValue,因为它不在项目列表中。 怎么回事 现象&#xff1a; 在用户控件的page_load事件里绑定下拉框&#xff0c;报上面错误 解决&#xff1a; 将下拉框绑定&#xff0c;放在page_Init事件里 这可能跟服务器加载控件的生命过程有关系转载于:https…

springbot 注入多实例

方式一&#xff1a; 在需要多实例的类上加入注解&#xff1a; Scope("prototype") 方式二&#xff1a; 在启动类上加入&#xff1a; BeanScope(value ConfigurableBeanFactory.SCOPE_PROTOTYPE, proxyMode ScopedProxyMode.TARGET_CLASS)public PrototypeClass…

javascript日历插件

javascript日历插件 原文:javascript日历插件javascript日历插件 最近在尝试着写javascript日历插件&#xff0c;所以也到github上看国外人日历源码&#xff0c;或者国内人写的好点的&#xff0c;也在研究点&#xff0c;虽然看到网上有一大把的日历控件&#xff0c;但是没有几个…

idea 重启

1、通过File–>Invalidate Caches/Restar...进入重启窗口 2、选择自己所需要的重启方式&#xff0c;四个按钮&#xff0c;一共三种重启方式&#xff1a; Invalidate and Restart 清空缓存并重启。Invalidate 清除缓存&#xff0c;下次打开重启。Cancel 取消。Just Restart …

Kernel Page Global Directory (PGD) of Page table of Process created in Linux Kernel

Kernel Page Global Directory (PGD) of User process created 在早期版本: 在fork一个进程的时候&#xff0c;必须建立进程自己的内核页目录项&#xff08;内核页目录项要与用户空间的页目录放在同一个物理地址连续的页面上&#xff0c;所以不能共享&#xff0c;但所有进程的内…

POI 导出文件以文件流形式返回

POI工具类 import java.io.UnsupportedEncodingException; import javax.servlet.http.HttpServletResponse; import org.apache.poi.hssf.usermodel.HSSFCell; import org.apache.poi.hssf.usermodel.HSSFCellStyle; import org.apache.poi.hssf.usermodel.HSSFRow; import o…

Json串和java对象进行转时

json-lib-xxx.jarezmorph-xxx.jar //>依赖包 JsonConfig config new JsonConfig();//有选择性的过滤掉一些属性值 JSONUtils.getMorpherRegistry().registerMorpher( new DateMorpher(new String[] { "yyyy-MM-dd" }));//注册一个json转为java.util.date的日期格…