java消费kafka数据 sasl_ssl，kafka消费java代码

Java消费Kafka数据使用SASL_SSL认证

作为一名经验丰富的开发人员，我很乐意帮助初学者了解如何在Java 中使用带有SASL_SSL 身份验证的Kafka 数据。以下是实现此功能的步骤和代码示例。

步骤概览

以下概述了使用SASL_SSL 身份验证通过Java 使用Kafka 数据的步骤概述。

步骤说明1 添加Kafka 客户端依赖项2 配置Kafka Consumer 属性3 创建Kafka Consumer 实例4 订阅主题5 轮询消息并处理6 关闭Consumer

详细步骤和代码示例

1. 添加Kafka客户端依赖

首先，您需要将Kafka 客户端依赖项添加到项目的pom.xml 文件中。

登录后复制

依赖

groupIdorg.apache.kafka/groupId

artifactIdkafka-客户端/artifactId

版本2.8.0/版本

/依赖

1.2.3.4.5。

2. 配置Kafka消费者属性

要使用SASL_SSL 身份验证，必须配置以下属性：

登录后复制

属性props=new Properties();

props.put(\’bootstrap.servers\’, \’kafka_server:9092\’);

props.put(\’Security.Protocol\’, \’SASL_SSL\’);

props.put(\’sasl_mechanism\’, \’PLAIN\’);

props.put(\’sasl.jaas.config\’, \’org.apache.kafka.common.security.plain.PlainLoginModule 需要用户名=\\\’用户名\\\’ 密码=\\\’密码\\\’;\’);

props.put(\’组ID\’, \’测试组\’);

props.put(\’key.deserializer\’, \’org.apache.kafka.common.serialization.StringDeserializer\’);

props.put(\’value.deserializer\’, \’org.apache.kafka.common.serialization.StringDeserializer\’);

1.2.3.4.5.6.7.8。

3. 创建Kafka消费者实例

创建具有配置属性的Kafka 消费者实例。

登录后复制

KafkaConsumerString, String Consumer=new KafkaConsumer(props);

1.

4. 订阅主题

订阅您需要消费的主题。

登录后复制

Consumer.subscribe(Arrays.asList(\’your_topic\’));

1.

5. 轮询消息并处理

使用轮询方法轮询消息并处理每条消息。

登录后复制

而（真）{

ConsumerRecordsString, 字符串记录=Consumer.poll(Duration.ofMillis(100));

for (ConsumerRecordString, 字符串记录： 条记录) {

System.out.printf(\’收到消息：(%s,%s)%n\’, record.key(), record.value());

}

}

1.2.3.4.5.6。

6. 关闭消费者

消费完成后关闭消费者。

登录后复制

Consumer.close();

1.

结语

上述步骤和代码示例应该可以帮助您了解如何在Java 中通过SASL_SSL 身份验证使用Kafka 数据。我希望这篇文章对您有所帮助。如果您在安装过程中遇到任何问题，请随时与我们联系。

饼状图

下面是使用Mermaid 语法生成的饼图，显示了Kafka 消费者配置属性的分布。

分发Kafka 消费者配置属性

二十五

15%

15%

15%

十

十

十

分发Kafka 消费者配置属性

引导程序服务器

安全协议

sasl_机制

sasl.jaas.config

组号

密钥解串器

值解串器

引自【Apache Kafka 官方文档】（

Kafka 是一个分布式流处理平台，用于构建实时数据管道和流应用程序。

原作者： u_16175455 转载来源： https://blog.51cto.com/u_16175455/11548881

以上关于#Java消费Kafka数据sasl_ssl的相关内容来源网络，仅供参考。相关信息请参见官方公告。