#
打开终端执行下列命令1、zkserver start ----启动zk2、启动kafka 2.1 cd /usr/local/Cellar
了解好kafka的基础概念之后，可以开始动手，环境：centos7,官方教程http://kafka.apache.org/quickstart#quickstart_download安装java环境
提交消费kafka应用里面包含sasl.jaas.config，通常需要配置文件。但是打成jar包后的应用，通过classload读不到jar包中配置文件。需要初始化kafka时增加propertie
一、Kafka基础消息系统的作用应该大部份小伙伴都清楚，用机油装箱举个例子所以消息系统就是如上图我们所说的仓库，能在中间过程作为缓存，并且实现解耦合的作用。引入一个场景，我们知道中国移动，中国联通，中
Kafka是由Java编写的一个开源流处理平台，因为它强大的动作流数据处理功能而备受大数据开发者的欢迎。因而作为大数据的开发者，掌握Kafka也就掌握了大数据最重要的一项核心技术。本文是一篇新手入门K
#!/bin/sh#ps -ef | grep $proc_name | grep -v grep | awk '{print $2}'source /etc/profileproc_
1、zookeeper概念介绍 在介绍ZooKeeper之前，先来介绍一下分布式协调技术，所谓分布式协调技术主要是用来解决分布式环境当中多个进程之间的同步控制，让他们有序的去访问某种共享资源，防止造
前文摘要 在前面的文章《Kafka的Lag计算误区及正确实现》中介绍了如何计算消费者的消费滞后量(Lag)，并且讲解了如何调用Kafka的kafka.admin.ConsumerGroupComman
如何在项目中使用spring-kafka操作消费kafka？针对这个问题，今天小编总结这篇有关kafka的文章，希望能帮助更多想解决这个问题的朋友找到更加简单易行的办法。日志分析以下为日志记录，con
kafka集群每次启动都需要登录多台服务器操作，比较麻烦，安装了一个批量管理工具pssh，配置了ssh免秘钥登录，写了一个简单的shell脚本方便日常的批量启动、关闭操作。[root@kafka1&n
