登陆CDH页面，进入Kafka配置页面
搜索 advertised
修改advertised.host.name，这里我们有三台Broker，我们把每台的外网ip填写到对应的机器上
advertised.port不填写
我们kafka的端口设置的是9099
将外网端口9099开放，允许外网访问 （这里不做介绍ÿ
CDH 版本 Kafka 外网设置
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/509726.shtml
如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！相关文章
OpenTSDB 安装
下载目录
https://github.com/OpenTSDB/opentsdb/releases
https://github.com/OpenTSDB/opentsdb/releases/download/v2.4.0/opentsdb-2.4.0.noarch.rpm
安装 GnuPlot
yum install gnuplot -y 直接安装OpenTSDB会报错 [rootecs-t-001-0001 openTSDB]# rpm -ivh opentsdb-2.…
HBase原理 – snapshot 快照
目录
snapshot（快照）基础原理
snapshot能实现什么功能？
hbase snapshot用法大全
hbase snapshot分布式架构－两阶段提交
snapshot核心实现
clone_snapshot如何实现呢？
其他需要注意的
参考文献 更多信息可参考《…
linux如何自动化部署脚本实现免密登录并访问资源
任务把weijie主机jdk文件安装到weijie1中。 首先再各台主机中安装必要的命令： expect、wget、httpd、ssh 执行命令 如：expect提示命令不存在，则分别安装命令
yum install expect
yum install wget
yum install httpd
yum install ssh
开…
时序数据库技术体系 – InfluxDB TSM存储引擎之数据读取
任何一个数据库系统内核关注的重点无非：数据在内存中如何存储、在文件中如何存储、索引结构如何存储、数据写入流程以及数据读取流程。关于InfluxDB存储内核，笔者在之前的文章中已经比较全面的介绍了数据的文件存储格式、倒排索引存储实现以及数据写入流…
java多线程之生产者和消费者问题
线程通信:不同的线程执行不同的任务,如果这些任务有某种关系,线程之间必须能够通信,协调完成工作.
经典的生产者和消费者案例(Producer/Consumer):分析案例:1):生产者和消费者应该操作共享的资源(实现方式来做).2):使用一个或多个线程来表示生产者(Producer).3):使用一个或多个…
时序数据库技术体系 – InfluxDB TSM存储引擎之数据写入
之前两篇文章笔者分别从TSM File文件存储格式、倒排索引文件存储格式这两个方面对InfluxDB最基础、最底层也最核心的存储模块进行了介绍，接下来笔者会再用两篇文章在存储文件的基础上分别介绍InfluxDB是如何处理用户的写入（删除）请求和读取请…
zookeeper结构和命令详解
1.1. zookeeper特性1、Zookeeper：一个leader，多个follower组成的集群
2、全局数据一致：每个server保存一份相同的数据副本，client无论连接到哪个server，数据都是一致的
3、分布式读写，更新请求转发…
时序数据库技术体系 – InfluxDB 多维查询之倒排索引
在时序数据库概述一文中，笔者提到时序数据库的基础技术栈主要包括高吞吐写入实现、数据分级存储｜TTL、数据高压缩率、多维度查询能力以及高效聚合能力等，上文《时序数据库技术体系 – InfluxDB存储引擎TSM》基于InfluxDB存储引擎TSM介绍了时序…
在Eclipse中如何操作zookpeer
导入jar包 jar包下载链接 代码解析 package com.itcast.zookpeer.zk;import java.io.IOException;
import java.util.List;import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apac…
Linux 系统进程守护工具 cesi + superviosr
一、安装 Supervisor
pip install supervisor
使用 echo_supervisord_conf 命令生成默认配置文件
echo_supervisord_conf > /etc/supervisord.conf
配置文件说明
位置：etc/supervisord.conf内容：# 指定了socket file的位置
[unix_http_server]
f…
Docker 服务器安装（一）
使用官方安装脚本自动安装
安装命令如下：
curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun
也可以使用国内 daocloud 一键安装命令：
curl -sSL https://get.daocloud.io/docker | sh
设置docker 加速器
sudo curl -sSL https…
Docker 入门使用 （二）
配置国内的源
> /etc/docker/daemon.json{"registry-mirrors" : ["https://mirror.ccs.tencentyun.com","http://registry.docker-cn.com","http://docker.mirrors.ustc.edu.cn","http://hub-mirror.c.163.com"],"…
ElasticSearch sql 插件安装
PS：6.3 开始 ElasticSearch 自身已经支持SQL查询。
github地址：https://github.com/NLPchina/elasticsearch-sql
一、在线安装
直接执行
./bin/elasticsearch-plugin install https://github.com/NLPchina/elasticsearch-sql/releases/download/6.3.…
zookpeer实现对服务器动态上下线的监听
服务器动态上下线程序的工作机制
服务器代码： 补充：volatile关键字：java中一切都是对象，当多个线程操作同一个对象时候，该对象会放在堆内存中，而多个线程相当于在多个栈中，当A线程想要去除对…
![Result window is too large, from + size must be less than or equal to: [10000] but was [12390]. See](https://img-blog.csdnimg.cn/20210409142636494.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nc2hlbmdoYW5n,size_16,color_FFFFFF,t_70)
Result window is too large, from + size must be less than or equal to: [10000] but was [12390]. See
ES 查询报错
Caused by: java.lang.IllegalArgumentException: Result window is too large, from size must be less than or equal to: [10000] but was [12390]. See the scroll api for a more efficient way to request large data sets. This limit can be set by chan…
java中泛型学习总结
为什么需要使用泛型:
1):存储任意类型的数据在集合中 ,但是取出来都是Object类型的,此时就得强转.List list new ArrayList();list.add(1);
//Interger类型Object ele list.get(0);
//现在需要调用Interger类中的方法I
nterger num (Interger) ele;System.out.println(num);…
别说“我已经很努力了”
转自：http://blog.csdn.net/foruok/article/details/40247543 我们程序员的努力与挣扎有时非常尴尬，如果没有结果，都是徒然，都是说不得说不得…… 我自己做项目经理时，干的项目也经常延期……非常惭愧。而延期其实对研…
Java集合框架-概述
Java集合框架的由来: 其实在Java2(jdk1.2)之前，Java是没有完整的集合框架的。它只有一些简单的可以自扩展的容器类，比如Vector，Stack，Hashtable等。 为什么存在容器类: 容器类(集合类)可以存储多个数据,既然数组可以存储多个数据…
MySQL Binlog增量同步工具go-mysql-transfer实现详解
go-mysql-transfer产品手册:https://www.kancloud.cn/wj596/go-mysql-transfer/2111996
一、 概述
工作需要研究了下阿里开源的MySQL Binlog增量订阅消费组件canal，其功能强大、运行稳定，但是有些方面不是太符合需求，主要有如下三点&#x…