一、功能管理多个kafka集群便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)选择你要运行的副本基于当前分区状况进行可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=……继续阅读 » 开心洋葱 7年前 (2018-07-08) 1795浏览 0评论1494个赞
类似于数据库的连接池(+) (#)事件处理线程说明如果事件处理的逻辑能迅速完成，并且不会发起新的IO请求，比如只是在内存中记个标识，则直接在IO线程上处理更快，因为减少了线程池调度。但如果事件处理逻辑较慢，或者需要发起新的IO请求，比如需要查询数据库，则必须派发到线程池，否则IO线程阻塞，将导致不能接收其它请求。如果用IO线程处……继续阅读 » 开心洋葱 7年前 (2018-07-07) 3002浏览 0评论2804个赞
[2018-07-07 10:04:28,974] INFO Result of znode creation at /brokers/ids/0 is: SESSIONEXPIRED (kafka.zk.KafkaZkClient)[2018-07-07 10:04:28,989] INFO Socket connection established t……继续阅读 » 开心洋葱 7年前 (2018-07-07) 2637浏览 0评论1565个赞
kafka服务起动报错[2018-07-07 08:10:26,914] ERROR Error while creating log for __consumer_offsets-11 in dir \tmp\kafka-logs (kafka.server.LogDirFailureChannel)java.io.IOException: Map f……继续阅读 » 开心洋葱 7年前 (2018-07-07) 2857浏览 0评论2503个赞
oracle存储过程和存储函数过程和函数区别在于：存储过程没有返回值存储函数有返回值CREATE [or replace] PROCEDURE 过程名（参数列表）ASPLSQL了程序体;参数列表( test in number)test参数名in 是输入参数number 参数为数字类型存储过程调用方式：1、exec 过程名;2、在P……继续阅读 » 开心洋葱 7年前 (2018-07-02) 2338浏览 0评论1518个赞
[已解决] dubbo注册服务报错（java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy）解决}, dubbo version: 2.6.1, current host: 10.8.0.62018-06-23 23:29:12,174 DEBUG [org.jboss.netty.c……继续阅读 » 开心洋葱 7年前 (2018-06-23) 3054浏览 3评论1711个赞
[org.springframework.web.context.ContextLoader] – Root WebApplicationContext: initialization started[org.springframework.web.context.support.XmlWebApplicationContext] –……继续阅读 » 开心洋葱 7年前 (2018-05-11) 2620浏览 0评论1715个赞
五月 18, 2018 1:55:23 下午 org.apache.tomcat.util.digester.SetPropertiesRule begin警告: [SetPropertiesRule]{Server/Service/Engine/Host/Context} Setting property ‘source’ to ……继续阅读 » 开心洋葱 7年前 (2018-04-18) 2435浏览 4评论827个赞
以太坊矿池源码区块链包含：以太坊矿池-环境安装以太坊矿池-矿池安装以太坊矿池-部署矿池以太坊矿池-使用ethminer测试源码下载：Geth在以太坊智能合约开发中最常用的工具（必备开发工具），一个多用途的命令行工具。熟悉Geth可以让我们有更好的效率，大家可收藏起来作为Geth命令用法手册。 本文主要是对geth help的翻译，基于最新的ge……继续阅读 » 开心洋葱 7年前 (2018-04-18) 2548浏览 29评论2423个赞
scala教程 – spark应用之scala语言编程入门（二）附送国内scala镜像下载地址：http://distfiles.macports.org/scala2.10///函数：scala> def num3(number:Int*)={var retult=0;for(element num3(3,3,4,5)res0: Int = 15……继续阅读 » 开心洋葱 7年前 (2018-04-13) 1173浏览 0评论1145个赞
scala教程 – spark应用之scala语言编程入门（一）安装scalahttps://downloads.lightbend.com/scala/2.12.5/scala-2.12.5.msiwindwos cmd 输入scalaC:\Users\yang>scalaWelcome to Scala 2.12.5 (Java……继续阅读 » 开心洋葱 7年前 (2018-04-13) 1968浏览 0评论2091个赞
Spring Cloud Zuul Api GateWay Errors***************************APPLICATION FAILED TO START***************************Description:Parameter 0 of method sendResponseFi……继续阅读 » 开心洋葱 7年前 (2018-03-29) 2189浏览 1评论1103个赞
【已解决】No alive nodes found in your cluster错误php 集成Elasticsearch 时候，查询出现这个错，请检查配置的服务器IP是否正确，服务器是否开启。需要指定节点的ip和端口号，示例代码如下：……继续阅读 » 开心洋葱 7年前 (2018-03-23) 3752浏览 0评论1122个赞
ERROR: [5] bootstrap checks failed[1]: initial heap size [31457280] not equal to maximum heap size [1073741824]; this can cause resize pauses and prevents mlockall from locking th……继续阅读 » 开心洋葱 7年前 (2018-03-23) 1494浏览 9评论1567个赞
RocketMQ 管理命令参考大全 sh mqadmin1.1. 控制台使用RocketMQ提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker等信息的管理；l 登录控制台：首先进入RocketMQ工程，进入/RocketMQ/bin在该目录下有个mqadmin脚本l 查看帮助：在mqadmin下可以查看有哪些命令sh ……继续阅读 » 开心洋葱 7年前 (2018-03-10) 2909浏览 0评论1042个赞
export JAVA_HOME=/home/yang/java/export JRE_HOME=$JAVA_HOME/jreexport CLASSPATH=.:$JAVA_HOME/lib:$JRE_HOME/lib:$CLASSPATHexport PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATHexport M2……继续阅读 » 开心洋葱 7年前 (2018-03-08) 2841浏览 0评论942个赞
geth –networkid 123 –dev –datadir data1 –rpc –rpcaddr 47.104.228.59 –rpcport 8989 –port 3000 //自动创建矿区geth attach ipc:geth.ipc //进入矿区eth.……继续阅读 » 开心洋葱 7年前 (2018-02-17) 2721浏览 0评论1230个赞
单 master 模式也就是只有一个 master 节点，称不上是集群，一旦这个 master 节点宕机，那么整个服务就不可用，适合个人学习使用。多 master 模式多个 master 节点组成集群，单个 master 节点宕机或者重启对应用没有影响。优点：所有模式中性能最高缺点：单个 master 节点宕机期间，未被消费的消息在节点恢复之前……继续阅读 » 开心洋葱 7年前 (2018-02-10) 3014浏览 0评论236个赞
RocketMQ 架构由这张图可以看到有四个集群，分别是 NameServer 集群、Broker 集群、Producer 集群和 Consumer 集群：NameServer: 提供轻量级的服务发现和路由。 每个 NameServer 记录完整的路由信息，提供等效的读写服务，并支持快速存储扩展。Broker: 通过提供轻量级的 Topic 和……继续阅读 » 开心洋葱 7年前 (2018-02-10) 1371浏览 0评论2716个赞
RocketMQ 单主部署快速入门 1、clone 源码并用 maven 编译git clone https://github.com/alibaba/RocketMQ.git /opt/RocketMQcd /opt/RocketMQ && mvn -Prelease-all -DskipTests c……继续阅读 » 开心洋葱 7年前 (2018-02-10) 2857浏览 0评论719个赞
生成索引后 可以使用 – -groupsort 参数排序出每个用户总成绩的排行。php 中使用SphinxClient::setGroupBy方法。配置文件如下：先上一个简单的配置：……继续阅读 » 开心洋葱 7年前 (2018-01-03) 2206浏览 0评论505个赞
……继续阅读 » 开心洋葱 7年前 (2017-12-21) 2716浏览 0评论563个赞
10分钟学习大数据之hadoop实战经典-第04讲 Hadoop集群构建硬件选择、集群规模、网络拓扑、机架感知等内容提纲：Hadoop硬件选择最低要求中央处理器：两个四核英特尔 Xeon 2.0 GHz CPU内存：8G ECC RAM存储器：4 x TB SATA 磁盘网络：千兆位以太网网络拓扑结构机架感知……继续阅读 » 开心洋葱 8年前 (2016-12-09) 2428浏览 0评论2428个赞
10分钟学习大数据之hadoop实战经典-第03讲Hadoop集群安装解析内容提纲：……继续阅读 » 开心洋葱 8年前 (2016-12-09) 2704浏览 0评论1092个赞
10分钟学习大数据之hadoop实战经典-第02讲10分钟从技术角度理解Hadoop Hadoop的核心HDFS: Hadoop Distributed File System 分布式文件系统MapReduce：并行计算框架Yarn：集群资源管理和调度框架Hadoop是什么？适合大数据的分布式存储、计算、资源管理平台作者：Do……继续阅读 » 开心洋葱 8年前 (2016-12-09) 2456浏览 0评论1002个赞
Hadoop简易实战入门经典教程–第01讲为什么会有第一代大数据技术Hadoop和第二代大数据技术Spark？内容提纲：大数据要解决的三大核心问题存储多种计算范式处理速度Hadoop+SparkHadoopOne stack to rule them allSparkThe codebase in Spark 1.0……继续阅读 » 开心洋葱 8年前 (2016-12-09) 1364浏览 0评论1363个赞
![ERROR [KafkaServer id=0] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)](https://blog.75271.com/wp-content/themes/com75271/timthumb.php?src=https://blog.75271.com/wp-content/themes/com75271/css/img/pic/2.jpg&h=123&w=200&q=90&zc=1&ct=1)
![[未解决]kafka服务起动报错](https://blog.75271.com/wp-content/themes/com75271/timthumb.php?src=https://blog.75271.com/wp-content/themes/com75271/css/img/pic/5.jpg&h=123&w=200&q=90&zc=1&ct=1)
![[已解决] dubbo注册服务报错（java.lang.NoClassDefFoundError: org/apache/curator/RetryPolicy）解决](https://blog.75271.com/wp-content/themes/com75271/timthumb.php?src=https://blog.75271.com/wp-content/themes/com75271/css/img/pic/1.jpg&h=123&w=200&q=90&zc=1&ct=1)
