通过VirtualBox安装多台虚拟机，实现集群环境搭建。 优势：一台电脑即可。 应用场景：测试，学习。 注意事项：请严格按照文档操作，作者已经按照文档操作实现环境搭建。 内附百度网盘下载地址，有hadoop+zookeeper+spark+kafka等等·····需要的安装包和配置文件

spring-kafka spring集成kafka的例子，包含生产者和消费者

mmo服务器 介绍 使用Java，netty，zookeeper，spring boot和mongo，redis工具开发游戏热更新分布式框架。 客户端和网关使用TCP定制协议，Intranet消息转发使用GRPC转发，所有无状态服务都可以水平扩展，状态服务可以通过分区，状态绑定和其他规则进行水平扩展。 该项目的基本架构如下所示： 模组 可以热更新在脚本末尾作为项目的项目模块结尾的逻辑脚本。 框架基础核心逻辑，网络通信，线程模型，通用工具类 通用逻辑代码 Protobuf消息，grpc服务 消息路由 登录认证 游戏演示 Web后台管理，GM等 服务器资源文件，Docker脚本，文档等 mmo

start.sh #!/bin/bash java -Xms512M -Xmx512M -Xss1024K -XX:PermSize=256m -XX:MaxPermSize=512m \ -cp KafkaOffsetMonitor-assembly-0.4.6-zjz.jar \ com.quantifind.kafka.offsetapp.OffsetGetterWeb \ --offsetStorage kafka \ --kafkaBrokers ip1:ports,ip2:ports,ip3:ports \ --zk ip1:ports,ip2:ports,ip3:ports \ --port 8181 \ --refresh 10.seconds \ --retain 5.days \ --dbName offsetapp_kafka 1>out.log 2>err.log & stop.sh #!/bin/bash killnum=`jps | grep OffsetGetterWeb | awk '{print $1}'` kill -9 ${killnum} echo "OK...."

kafka +zookeper 官方包,可以window，linux 启动，启动前需配置链接服务ip

Kafka跨集群容灾备份 1、使用场景 2、MirrorMaker架构 3、MirrorMaker工具使用 4、验证消息是否拷贝成功 5、跨机房备份案例 6、注意事项

我就废话不多说了，直接 上代码吧！ import kafka.api.PartitionOffsetRequestInfo; import kafka.common.TopicAndPartition; import kafka.javaapi.OffsetResponse; import kafka.javaapi.PartitionMetadata; import kafka.javaapi.TopicMetadata; import kafka.javaapi.TopicMetadataRequest; import kafka.javaapi.consumer.SimpleConsu

网上Kafka集群搭建的教程很多了，但真正能用的不多，本文提供了详细的步骤说明，绝对可用

window 64位 亲测可用kafkaTool

利用flume将mysql的数据同步到kafak，flume是基于CDH6.2.0安装的。解决已下问题：java.lang.NoSuchMethodError:    org.apache.flume.Context.getSubProperties(Ljava/lang/String;)Lcom/google/common/collect/ImmutableMap;