Kafka集成测试中无法设置SASL启用机制。

出现此问题的原因是SASL未正确配置。在使用Kafka集成测试进行Kafka连接测试时，需要正确配置SASL机制以达到连接认证的目的。以下是一段示例代码，可供参考：

Properties props = new Properties();
props.put("bootstrap.servers","localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.kerberos.service.name", "kafka");
props.put("sasl.mechanism", "GSSAPI");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("test-topic"));
while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}

在这段代码中，我们指定了以下属性：

• security.protocol：指定使用SASL验证，此处使用的是SASL_PLAINTEXT。
• sasl.mechanism：指定使用的SASL机制。在此示例中，我们使用的是GSSAPI。您可以根据需要选择要使用的SASL机制。
• sasl.kerberos.service.name：指定Kerberos服务名称。在此处，我们设置其为'kafka”。
• 方便起见，我们还指定了一些基本属性，如主题、群组ID以及序列化程序。

在配置SASL机制和其他参数后，我们可以启动Kafka Consumer并订阅指定的主题，从而运行测试，如果一切正常，我们应该能够接收到消息。