KafkaBroker验证失败-凭据无效

此错误通常是由于Kafka Broker和Kafka客户端之间的安全凭据不匹配引起的。需要检查Kafka Broker和Kafka客户端之间的安全凭据和配置是否正确匹配。以下是可能的解决方案：

1. 检查Kafka Broker端口和安全协议的配置是否正确。

2. 检查Kafka客户端的安全协议和凭据配置是否正确。

3. 检查Kafka Broker和Kafka客户端之间的SSL证书是否匹配。

以下是一个Java代码示例，演示如何配置Kafka客户端的安全凭据：

Properties props = new Properties();
props.put("bootstrap.servers", "kafka-broker1:9092,kafka-broker2:9092");
props.put("security.protocol", "SSL");

props.put("ssl.truststore.location", "/path/to/truststore.jks");
props.put("ssl.truststore.password", "truststore-password");

props.put("ssl.keystore.location", "/path/to/keystore.jks");
props.put("ssl.keystore.password", "keystore-password");
props.put("ssl.key.password", "key-password");

KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props, new StringSerializer(), new StringSerializer());

该示例中，我们使用SSL安全协议，并提供了信任库和密钥库的位置和密码，以及相应的密码。请注意：这只是示例，并且需要按照实际情况进行适当的更改。