logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

zookeeper 中 Watcher 通知机制的一点理解

首先,ZooKeeper 提供了分布式数据的发布/订阅功能。这让我想到一种模式,观察者模式:一个典型的发布/订阅模型系统定义了一种一对多的订阅关系,能够让多个订阅者同时监听某一个主题对象,当这个主题自身状态变化时,会通知所有订阅者,试它们能够做出相应的处理。那 ZooKeeper 是不是也是使用了这个经典的模式呢?在 ZooKeeper 中,引入了 Watcher 机制来实现这种分布式的通知功能。

#zookeeper
在 kafka 的 broke 和 client 之间加入 SSL 双向认证

参考:https://kafka.apache.org/documentation/#security单向认证首先实现单向的认证,即,client 对 broker 的认证。就像浏览器对服务器的认证一样。注:密钥生成过程中的密码统一为test123。为broke生成keystore第一步是为集群的每台机器生成密钥和证书,可以使用java的keytool来生产。我们将生成密钥

#kafka
kafka 对外提供服务方案简述

背景首先,用户数据会经过 kafka 队列传递到我们的业务层。我们希望用户能够通过一个通用层接入我们的kafka服务,但是有的用户希望能够直接连到我们的 kafka 上面,这就需要我们的 kafka 对外暴露broke服务以便被接入。那么如何保证用户数据接入的可靠性和安全性,就成为了这篇文章的主要内容。目标我们希望其他公司数据接入的方式尽量松耦合,尽量不依赖内部架构,而对于一些用户要直

#kafka
kafka 简单安装以及java小demo

系统:centos7下载kafka:http://kafka.apache.org/downloads ,我下载的版本为 kafka_2.11-0.10.1.0.tgz 。安装ZooKeeper,默认已经安装好 zookeeper-3.4.9 并已经启动。第1步,下载解压 kafka:# tar -xzf kafka_2.11-0.10.1.0.tgz# cd kafka_

#kafka
到底了