打开防火墙端口CentOS/RHEL 7:sudo firewall-cmd --zone=public --add-port=8080/tcp --permanentsudo firewall-cmd --reload#如果不使用“--permanent”标记，把么防火墙规则在重启后会失效。CentOS/RHEL 6:sudo iptables -I INP...

前言软件环境:主机IP系统hostnameserver1192.168.0.57centos7.4kafka-1server2192.168.0.58centos7.4kafka-2server3192.168.0.59centos7.4kafka-3软件依赖:...

前言软件环境:一台虚拟主机，配置IP为192.168.0.56。软件依赖:启用kafka自带的Zookeeper服务Zookeeper是用java写的所以需要搭建JAVA环境(JDK版本 >= 1.7)。1.安装JDK目前官网不能直接下载，在网上找到1.8.0版本安装包下载到本地。1.1.下载jdk#远程登陆主机 (使...

安装错误:#错误rdkafka_topic.c:321:59: error: 'Z_DEFAULT_COMPRESSION' dndeclared (fitrst use in this function)#原因:缺少zlib-devel库，编译不通过。查询zlib相关安装包可以看到zlib-devel没有安装[root@localhost ~]# rpm -qa|grep z...

前言针对golang的 kafka client有很多开源package，例如sarama, confluent等等。在使用sarama 包时，高并发中偶尔遇到crash。于是改用confluent-kafka-go，其简单易用，并且表现稳定。confluent-kafka-go，是kafka官网推荐的golang package。官网地址: https://github.c...