RocketMQ 5.xµÄÉú²úÕߣ¬Ó¦¸ÃÔõôÅ䣿

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client-java</artifactId>
    <version>5.0.5</version>
</dependency>

ʹÓÃProducerBuilderÀ´´´½¨Ò»¸öÉú²úÕßʵÀý

Producer producer = ProducerBuilder.builder()
    .setClientConfiguration(ClientConfiguration.newBuilder()
        .setEndpoints("rmq-xxx.rocketmq.xxx.tencenttdmq.com:8081")
        .enableSsl(false)
        .setCredentialProvider(new StaticSessionCredentialsProvider("yourAccessKey", "yourSecretKey"))
        .build())
    .setTopics("yourNormalTopic")
    .build();