1、连接demo是采用的这篇博客中的内容： https://blog.csdn.net/weixin_39098944/article/details/108067005 主要代码如下： （1）添加依赖 1 <dependency> 2 <groupId>org.apache.kafka</grou ...
分类：
编程语言 时间：
2021-04-30 12:13:39
阅读次数：
0
1. 搭建测试环境安装 1.1 下载并启动docker-compose容器 # 该 Docker Compose 中包含的容器有： # DataGen：数据生成器。容器启动后会自动开始生成用户行为数据，并发送到 Kafka 集群中。默认每秒生成 1000 条数据，持续生成约 3 小时。也可以更改 d ...
分类：
数据库 时间：
2021-04-28 11:43:18
阅读次数：
0
Kafka 基本术语 对于 Kafka 基本原理的介绍，可以通过对以下基本术语的介绍进行。 2.1.1 Topic 主题。在 Kafka 中，使用一个类别属性来划分消息的所属类，划分消息的这个类称为 topic。 topic 相当于消息的分类标签，是一个逻辑概念。 2.1.2 Partition 分 ...
分类：
其他好文 时间：
2021-04-26 13:52:08
阅读次数：
0
kafka功能简单测试 启动zookeeper 启动zk命令： ./zhServer.sh start 启动akfka（注意server.properties的配置） 启动akfka命令：./kafka-server-start.sh /home/hadoop/app/kafka_2.11-0.9. ...
分类：
其他好文 时间：
2021-04-24 13:16:11
阅读次数：
0
03. Dubbo管理控制台 1. 作用 主要包含： 服务管理 路由规则 动态配置 服务降级 访问控制 权重调整 负载均衡等管理功能 如我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我 们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用， ...
分类：
其他好文 时间：
2021-04-22 16:22:15
阅读次数：
0
spring: kafka: bootstrap-servers: 112.126.74.249:9092,112.126.74.249:9093 ###########【初始化生产者配置】########### producer: # 应答级别:多少个分区副本备份完成时向生产者发送ack确认(可选 ...
分类：
其他好文 时间：
2021-04-21 12:08:09
阅读次数：
0
命令基本语法 功能描述 help 显示所有操作命令 ls path [watch] 显示所有操作命令 ls path [watch] 查看当前节点数据并能看到更新次数等数据 create 普通创建， -s 含有序列， -e 临时（重启或者超时消失） get path [watch] 获得节点的值 s ...
分类：
其他好文 时间：
2021-04-20 15:33:29
阅读次数：
0
ACL全称为Access Control List 即访问控制列表，用于控制资源的访问权限。zookeeper利用ACL策略控制节点的访问权限，如节点数据读写、节点创建、节点删除、读取子节点列表、设置节点权限等 集群中机器的数量并不是越多越好，一个写操作需要半数以上的节点ack，所以集群节点数越多， ...
分类：
其他好文 时间：
2021-04-20 15:33:16
阅读次数：
0
通过对 Zookeeper 中丰富的数据节点进行交叉使用，配合 Watcher 事件通知机制，可以非常方便的构建一系列分布式应用中涉及的核心功能，比如 数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列 等功能 1. 数据发布/订阅 当某些数据由 ...
分类：
其他好文 时间：
2021-04-20 15:29:56
阅读次数：
0
市场上常见的消息队列有如下： ActiveMQ：基于JMS ZeroMQ：基于C语言开发 RabbitMQ：基于AMQP协议，erlang语言开发，稳定性好 RocketMQ：基于JMS，阿里巴巴产品 Kafka：类似MQ的产品；分布式消息系统，高吞吐量 用rabbitmq比较多 ...
分类：
其他好文 时间：
2021-04-19 15:27:26
阅读次数：
0
