kafka集群搭建,比较简单,直接略过,这里使用最新版v3.1.0,同时配置kafka通过Kerberos认证连接,配置之后,通过客户端连接进行测试。
需要注意的地方:
1、IP地址修改为机器的实际IP地址 2、hostname修改为服务器的实际域名或者机器名称 3、文件路径/opt/kafka/config/kafka.keytab修改为实际的路径 4、消费kafka的group_id修改为需要的IP,默认是t001
需要安装依赖库如下:
yum install -y krb5-workstation pip3 install gssapi kafka-python
生成Kerberos认证文件:
kadmin.local -q "addprinc -randkey kafka/hostname@TORCH.COM" kadmin.local -q "xst -k kafka.keytab -norandkey kafka/hostname@TORCH.COM"