windows安装kafka环境

1.安装jdk8

参考教程java8安装教程_java8u371安装教程-CSDN博客

下载kafak安装包:

kafka_2.12-3.6.1.tgz

解压:

启动ZooKeeper软件,kafka内部已近集成了该软件。

  • 进入Kafka解压缩文件夹的config目录,修改zookeeper.properties配置文件

提前创建好数据目录:

修改为:

E:/Code/kafka/data/zk

启动,进入目录下:

E:\Code\kafka\bin\windows

创建快捷运行脚本:

call bin/windows/zookeeper-server-start.bat config/zookeeper.properties

可以看到kafka运行后,能够生成对应的文件夹及文件。

启动Kafka:
进入Kafka解压缩文件夹的config目录,修改server.properties配置文件。

修改为如下:

E:/Code/kafka/data/kafka

其他配置保持默认即可。

启动:前提是需要先运行zk。

关闭顺序为:先关闭kafka,后关闭zk,到此测试环境就已经搭建好了。

同理,创建启动kafka的快捷脚本。

call bin/windows/kafka-server-start.bat config/server.properties

生成的文件:

C#测试发布订阅:

创建控制台项目,安装依赖;

步骤 2: 创建 Kafka 生产者
using Confluent.Kafka;
using System;
using System.Threading;class Program
{static void Main(){var config = new ProducerConfig{BootstrapServers = "your_kafka_bootstrap_servers"};using (var producer = new ProducerBuilder<Null, string>(config).Build()){string topic = "your_kafka_topic";for (int i = 0; i < 10; i++){string message = $"Message {i}";var deliveryReport = producer.ProduceAsync(topic, new Message<Null, string> { Value = message }).Result;Console.WriteLine($"Delivered '{deliveryReport.Value}' to '{deliveryReport.TopicPartitionOffset}'");}}}
}

参考教程如下:

C#整合kafuka_c# kafka-CSDN博客

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

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

相关文章

傲软抠图一款专为抠图打造的AI智能抠图应用,智能识别人物物体抠图软件,无广vip版 v1.8.1

软件介绍 傲软抠图&#xff0c;作为一款高度专业化的智能人工智能图片处理软件&#xff0c;被设计专门用于执行精确的图像提取功能。该程序利用其先进的算法能动地识别和分辨图像中的人物或物体轮廓&#xff0c;并能够从原始图片材料中分离出带有透明背景的目标图像。除了自动…

Cisco Nexus9508交换机硬盘bug补丁SMU安装步骤

Cisco Nexus9508交换机硬盘bug补丁SMU安装步骤 1 背景 客户1台Nexus9508交换机&#xff0c;当前软件版本存在SSD硬盘BUG&#xff0c;需要打补丁 bug相关链接 https://quickview.cloudapps.cisco.com/quickview/bug/CSCvx21260 Conditions: This cli can be used for any NXO…

GIT 新建分支和合并分支

文章目录 前言一、新建分支二、切回老分支&#xff0c;保留新分支的更改三、合并分支 前言 本文主要针对以下场景进行介绍&#xff1a; 场景一&#xff1a;创建新的分支 当前分支(dev_1)已经开发完毕&#xff0c;下一期的需求需要在新分支(dev_2)上进行开发&#xff0c;如何创…

【网络】网络编程中的粘包问题

1. 什么是粘包问题&#xff1f; 粘包问题指的是在基于流的协议中&#xff0c;接收方收到的数据不是按照发送方发送的消息边界来划分的&#xff0c;而是多个消息粘在一起&#xff0c;或者一个消息被分割成多个部分接收。 2. 为什么会出现粘包问题&#xff1f; &#xff08;1&a…

[机缘参悟-187] - 《道家-水木然人间清醒1》读书笔记 - 真相本质 -10- 关系界限 - 一个人只有放下自我,才能看清世界的真相

目录 一、现实生活中&#xff0c;每个人都是盲人摸象 二、一个人认知的本质是神经网络的模型训练 三、每个人的认知具有局限 四、放下自我&#xff0c;就是跳出自我的认知局限 五、站在上帝的视角&#xff0c;俯瞰不同众生的千差万别的大脑认知系统 六、个体的独特性&…

【Linux】信号>信号产生信号处理信号保存信号详解

主页&#xff1a;醋溜马桶圈-CSDN博客 专栏&#xff1a;Linux_醋溜马桶圈的博客-CSDN博客 gitee&#xff1a;mnxcc (mnxcc) - Gitee.com 目录 1.信号入门 1.1 生活角度的信号 1.2 技术应用角度的信号 1.3 信号概念 1.4 信号处理常见方式概览 2.产生信号 2.1 通过终端按键…

打包要求 minCompileSdk 使用指定版本及以上

我当前的 compileSdkVersion 30&#xff0c;因为依赖了 androidx.core:core:1.9.0 它要求最低 compileSdkVersion 33。 那么如果我不想升级 compileSdkVersion 应该怎么办&#xff1f; 答&#xff1a;当然是降低 core:core 版本&#xff01; 看看谁依赖了这两个版本 android…

CAN笔记第二篇,车载测试继续学起来!

在CAN协议中&#xff0c;“帧”是一个包含完整信息的独立单元&#xff0c;它具有特定的格式和结构&#xff0c;以确保数据在CAN总线上的可靠传输。这里的“帧”字可以理解为&#xff1a; 完整性&#xff1a;一个帧包含了所有必要的信息&#xff0c;从起始到结束&#xff0c;都遵…

GEE深度学习——地代码作物分类(Vertex AI 机器学习MLPINGTAI )

低代码作物分类 AutoML 能以最小的技术投入创建和训练模型。本示例演示了使用 Vertex AI Python SDK 训练和部署一个 AutoML 表格式模型,然后从 Earth Engine 连接到该模型,对国家农业图像计划 (NAIP) 航空图像中的作物类型进行分类。 本教程的主要流程是为了将选好的训练数…

# 分布式链路追踪_skywalking_学习(2)

分布式链路追踪_skywalking_学习&#xff08;2&#xff09; 一、分布式链路追踪_skywalking &#xff1a;Rpc 调用监控 1、Skywalking(6.5.0) 支持的 Rpc 框架有以下几种&#xff1a; Dubbo 2.5.4 -> 2.6.0Dubbox 2.8.4Apache Dubbo 2.7.0Motan 0.2.x -> 1.1.0gRPC 1.…

LeetCode 968.监控二叉树 (hard)

968.监控二叉树 力扣题目链接(opens new window) 给定一个二叉树&#xff0c;我们在树的节点上安装摄像头。 节点上的每个摄影头都可以监视其父对象、自身及其直接子对象。 计算监控树的所有节点所需的最小摄像头数量。 贪心思路&#xff1a; 从下往上看&#xff0c;局部最…

excel数据导入到数据库的方法(二)

以前写了一篇excel导入数据到数据库的文章&#xff0c;是先将excel导入到datatable中在进行批量插入操作&#xff0c;实现数据的导入工作&#xff1b;最近在写一个上传数据服务时&#xff0c;发现有些许问题&#xff0c;在此予以更正&#xff0c;问题描述&#xff1a; 就会报异…

C++_vector简单源码剖析:vector模拟实现

文章目录 &#x1f680;1.迭代器&#x1f680;2.构造函数与析构函数⚡️2.1 默认构造函数vector()⚡️2.2 vector(int n, const T& value T())⚡️内置类型也有构造函数 ⚡️2.3 赋值重载operator⚡️2.4 通用迭代器拷贝⚡️2.5 vector(initializer_list<T> il)⚡️…

软件测试面试题(三)

一&#xff1a;软件测试的步骤是什么&#xff1f; 测试过程按4个步骤进行&#xff0c;即单元测试&#xff0c;集成测试&#xff0c;确认测试和系统测试及发版测试。 开始是单元测试&#xff0c;集中对用源代码实现的每一个程序单元进行测试&#xff0c;检查各个程序模块是否正…

vue3-hooks

命名规则&#xff1a;use--->谁相关.js/ts 举例&#xff1a; import {reactive} from vue import axios from axiosexport default function(){let dogList reactive({https://images.dog.ceo/breeds/pembroke/n02113023_4373.jpg })//方法 async function getDog(){try…

计算机网络基础 - 计算机网络和因特网(1)

计算机网络基础 计算机网络和因特网什么是 Internet?具体构造的的角度服务角度网络结构 网络边缘网络核心电路交换分组交换概述排队时延和分组丢失转发表和路由选择协议按照有无网络层的连接 分组交换 VS 电路交换 接入网DSL 因特网接入电缆因特网接入光纤到户 FTTH无线接入网…

MySQL数据源不停机迁移到AWS RDS MySQL

就在近期&#xff0c;谷歌云捅了个大篓子&#xff0c;误删除了一家投资公司&#xff08;Unisuper&#xff0c;管理着800亿美元基金&#xff09;在谷歌云所有地域的所有数据&#xff0c;删得相当彻底&#xff0c;连备份数据都没给人家留一个。 Unisuper 是一家澳大利亚退休金基…

C++-逻辑语句

if语句 基本格式&#xff1a; 只有判断结果为true&#xff0c;才会执行后续{}内的代码 if (要执行的判断&#xff0c;结果需是bool型) {判断结果true&#xff0c;才会执行的代码; }if (条件判断) { 如果判断结果为true&#xff0c;会执行的代码; }else{如果判断结果为false…

OS多核多线程锁记录笔记

自旋锁作用 自旋锁的是为了保护两个核上的公共资源&#xff0c;也就是全局变量&#xff0c;只有在一方也就是一个核抢到了自选锁&#xff0c;才能对公共资源进行操作修改&#xff0c;当然还有其他形似的锁如互斥锁&#xff0c;这里不比较两者的区别&#xff0c;以前没有深入的去…

常用shell命令总结(Linux命令)

当前目录 . 上一级目录 … 根目录&#xff0c;或者是目录拼接符 / 管道符&#xff08;左侧输出作为右侧输入&#xff09; | 上一个命令的返回码 $? 或 || 且 && cat 查看文档 cat XX.txt 加权限 chmod x 文件 chmod 777 文件 改变文件的所有者 chown newowne…