不多说，直接上干货！ 全网最详细的启动zkfc进程时，出现INFO zookeeper.ClientCnxn: Opening socket connection to server***/192.168.80.151:2181. Will not attempt to authenticate u ...
分类：
编程语言 时间：
2018-06-17 15:09:20
阅读次数：
503
1.概述 在Kafka0.9版本之前，Kafka集群时没有安全机制的。Kafka Client应用可以通过连接Zookeeper地址，例如zk1:2181:zk2:2181,zk3:2181等。来获取存储在Zookeeper中的Kafka元数据信息。拿到Kafka Broker地址后，连接到Kafk ...
分类：
其他好文 时间：
2018-06-17 10:52:32
阅读次数：
195
网上关于kafka集群的搭建，基本是单个broker和单个zookeeper，测试研究的意义不大。于是折腾了下，终于把正宗的Kafka集群搭建出来了，在折腾中遇到了很多坑，后续有时间再专门整理份搭建问题分析 docker compose.yml配置文件 启动集群 查看容器启动状态 ...
分类：
其他好文 时间：
2018-06-15 20:05:19
阅读次数：
1363
1.消息队列: 1.1 几个概念说明： Broker：简单来说就是消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Queue：消息队列载体，每个消息都会被投入到一个或多个队列。 Binding：绑定，它的作用就是把exchange和queue按照路由规则绑 ...
分类：
其他好文 时间：
2018-06-14 15:16:21
阅读次数：
188
kafka是干什么的，有和特性，我这里就不多说，详情自己研究官方文档。 0. 背景介绍 我需要在三台机器上分别部署kafka broker的实例，构建成一个集群。kafka的broker集群，是基于zookeeper作为协调器或者资源同步管理器的，主要是记录High Level Offset标记信息 ...
分类：
其他好文 时间：
2018-06-13 12:03:33
阅读次数：
294
public class LongRidesWithKafka { private static final String LOCAL_ZOOKEEPER_HOST = "localhost:2181"; private static final String LOCAL_KAFKA_BROKER ... ...
分类：
其他好文 时间：
2018-06-13 11:48:54
阅读次数：
186
Activemq-.xml1.加载properties配置参数。下面加载是访问broker的身份信息，即用户名和密码<beanclass="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"><propertyname="locations"><value>file:${
分类：
其他好文 时间：
2018-06-12 23:31:47
阅读次数：
697
写在前面:前一篇文字<<基于MQTT协议谈谈物联网开发-华佗写代码>>主要叙述了MQTT协议的编解码以及基于MQTT协议的一些常见应用场景,并以一个简单的消息推送系统作为例子阐述具体MQTT应用的开发,这篇文字继续叙述上述应用中Mqtt Broker部分的实现. 1.Mqtt Broker开源产品: ...
分类：
其他好文 时间：
2018-06-08 14:23:46
阅读次数：
500
认识 这里有几个概念，task、worker、broker。顾名思义，task 就是老板交给你的各种任务，worker 就是你手下干活的人员。 那什么是 Broker 呢？ 老板给你下发任务时，你需要 把它记下来， 这个它 可以是你随身携带的本子，也可以是 电脑里地记事本或者excel，或者是你的 ...
分类：
其他好文 时间：
2018-06-07 14:13:00
阅读次数：
187
1、mvn package --加载运行一个含有pom.xml的目录并生成target目录2、mvn dependency:tree 显示项目所有依赖的树状结构3、业务委托给了Spring Boot的SpringApplication类-通过调用run()执行4、mvn spring-boot:ru ...
分类：
编程语言 时间：
2018-06-06 15:17:04
阅读次数：
240
