文档首页> 分布式消息服务 DMS> 开发指南> Kafka普通版开发指南> Java SDK> 示例代码导读
更新时间：2022-02-21 GMT+08:00
查看PDF

示例代码导读

生产消息

分布式消息服务（DMS）的Kafka API兼容原生开源Kafka客户端，仅仅增加了用于身份认证和安全通信的客户端证书和SASL配置，用户只需要在创建KafkaProducer前传入上述两项配置，不需要修改任何其他Kafka业务代码，即可实现平滑迁移。

配置代码如下：

 Properties producerConfig = Config.getProducerConfig();
    producerConfig.put("ssl.truststore.location", Config.getTrustStorePath());
    System.setProperty("java.security.auth.login.config", Config.getSaslConfig());

创建生产者和发送消息的代码不需要任何修改。

消费消息

分布式消息服务（DMS）的Kafka API兼容原生开源Kafka客户端，仅仅增加了用于身份认证和安全通信的客户端证书和SASL配置，用户只需要在创建KafkaConsumer前传入上述两项配置，不需要修改任何其他Kafka业务代码，即可实现平滑迁移。

配置代码如下：

 Properties consumerConfig = Config.getConsumerConfig();
    consumerConfig.put("ssl.truststore.location", Config.getTrustStorePath());
    System.setProperty("java.security.auth.login.config", Config.getSaslConfig());

创建消费者和消费消息的代码不需要任何修改。

父主题： Java SDK