[toc] 集群启动 启动zookeeper集群 cd /usr/app/zookeeper/bin ./zkServer.sh start 依次启动。 启动kafka集群 cd /usr/app/kafka bin/kafka server satrt.sh daemon config/serve ...
分类：
其他好文 时间：
2019-12-07 16:34:29
阅读次数：
184
一个topic有多个partition，每个partition又有多个副本，在这些副本中又有一个leader和多个follower。 1）分区的原因 （1）方便在集群中扩展，每个Partition可以通过调整以适应它所在的机器，而一个topic又可以有多个Partition组成，因此整个集群就可以适 ...
分类：
其他好文 时间：
2019-12-06 00:31:27
阅读次数：
192
1、RabbitMQ简介 2、RabbitMQ安装及使用 3、RabbitMQ快速入门 4、交换机 RabbitMQ简介 各大主流中间件对比 ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线，并且它一 个完全支持 J M S 规范的消息中间件。 其丰富的 API 、多种集群 ...
分类：
其他好文 时间：
2019-12-05 12:55:30
阅读次数：
86
– zookeeper is not a recognized option主要原因是 Kafka 版本过高，命令不存在。 使用新版本： ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test -- ...
分类：
其他好文 时间：
2019-12-04 10:32:16
阅读次数：
84
环境 CentOS Linux release 7.7.1908 (Core) 拉取redis 5.0.7 镜像 创建挂载目录 下载redis.conf "redis.conf 地址" 进入目录并下载redis.conf 修改redis.conf 创建启动容器 参数解释 ...
分类：
其他好文 时间：
2019-12-02 19:24:03
阅读次数：
94
摘要： 媒体处理创建消息主题出现“Only one topic can be created!”错误 目前媒体处理每个用户只能开一个管道，无法创建多管道，所以会出现Only one topic can be created!这个错误。 媒体处理创建消息主题出现“Only one topic can ...
分类：
其他好文 时间：
2019-12-01 12:11:41
阅读次数：
139
1主题主题名称结构的URL：{persistent|non-persistent}://tenant/namespace/topic名称组成说明persistent/non-persistent持久和非持久tenant租户namespace命名空间主题的管理单元，用作相关主题的分组机制。大多数主题配置是在命名空间级别执行的。每个租户可以有多个命名空间topic名字的最后一部分无需显式创建新主题你不
分类：
其他好文 时间：
2019-11-29 19:54:17
阅读次数：
76
Pulsar官方文档概念和架构-MessagingConcepts中主要内容1消息组成|组成|说明||--------|--------||Value/datapayload|消息携带的数据，所有pulsar的消息携带原始bytes,但是消息数据也需要遵循数据shcema||Key|消息可以被Key打标签。这可以对topic压缩之类的事情起作用||Properties|用户定义属性的可选键/值映射
分类：
其他好文 时间：
2019-11-29 19:45:59
阅读次数：
200
kafka 生产者、消费者与分区的关系 背景 最近和海康整数据对接, 需要将海康产生的结构化数据拿过来做二次识别. 基本的流程: 海康大数据 kafka server 平台 Kafka 的 topic 正常过车 topic： BAYONET_VEHICLEPASS 违法过车 topic： BAYON ...
分类：
其他好文 时间：
2019-11-29 18:25:16
阅读次数：
73
