不同域kafka之间进行发送和消费数据时,需要开启acl认证,生产者和消费者都需要添加相关认证配置
kafka.consumer.saslJaasConfig = org.apache.kafka.common.security.scram.ScramLoginModule required username=“xxxx” password=“xxxxx”;
kafka.consumer.securityProtocol = SASL_PLAINTEXT
kafka.consumer.saslMechanism = PLAIN