SimpleConsumer怎么使用鉴权模式

在使用 Kafka 的 SimpleConsumer 进行鉴权时，需要进行以下步骤：

1. 配置 Kafka 服务器的鉴权模式。可以使用 Kafka 自带的身份验证机制，例如 SSL、SASL 或 Kerberos，也可以使用第三方身份验证插件。

2. 在 SimpleConsumer 中配置鉴权信息。可以通过以下代码设置：

Properties props = new Properties();
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");
props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"your-username\" password=\"your-password\";");

其中，`security.protocol` 设置为所使用的鉴权协议，例如 SASL_PLAINTEXT；`sasl.mechanism` 设置为鉴权机制，例如 PLAIN；`sasl.jaas.config` 设置为用户名和密码信息。

3. 创建 KafkaConsumer 对象并进行订阅。可以通过以下代码创建：

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Collections.singletonList("your-topic"));

其中，`props` 为上一步中设置的配置信息，`your-topic` 为所订阅的主题名称。

4. 接收消息。可以通过以下代码接收消息：

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(1000));
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}

通过以上步骤，就可以使用 SimpleConsumer 进行鉴权模式的 Kafka 消费了。