Kafka 组件操作

查看 pod 信息

kubectl get pod -n sso | grep tce-support-kafka-1-1

查看是否开启 Kafka 认证信息

kubectl get kafka -A | grep tce-support-kafka-1-1
kubectl edit kafka tce-tce-support-kafka-1-1 -nsso

auth: true 则为开启认证。

登录 Kafka pod

kubectl exec -it ${pod_name} -nsso bash
unset JMX_PORT KAFKA_OPTS KAFKA_LOG4J_OPTS KAFKA_HEAP_OPTS
cd $KAFKA_HOME/bin

获取 zk 连接信息

kfk_conn=$(cat /etc/kafka/server.properties |grep adver);kfk_conn=${kfk_conn#*//};echo $kfk_conn

获取 Kafka 连接信息

kfk_conn=$(cat /etc/kafka/server.properties |grep adver);kfk_conn=${kfk_conn#*//};echo $kfk_conn

查看 topic 是否创建成功

cat > /tmp/sasl.config << EOF
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
   username="xxx " \
   password="xxx";
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
EOF
./kafka-topics.sh --zookeeper $zk_conn –list  

在回显中确认依赖 Topic 是否存在。

  monitor-metric-tdsq
  monitor-metric-dcdb
  monitor-metric-mariadb