final String topic = "{Topic_Name}";     // The name of the Lite Topic you created in the console
final String accessKey = "{Access_Key}"; // The AccessKey of the role you created in the console
final String secretKey = "{Secret_Key}"; // The SecretKey of the role you created in the console
final String endpoints = "{EndPoints}";  // The cluster access point displayed in the console

final SessionCredentialsProvider sessionCredentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
final ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
    .setEndpoints(endpoints)
    .setCredentialProvider(sessionCredentialsProvider)
    .enableSsl(false)
    .build();

final Producer producer = provider.newProducerBuilder()
    .setClientConfiguration(clientConfiguration)
    .setTopics(topic)
    .setMaxAttempts(3)
    .build();

final byte[] body = "This is a lite message of TDMQ RocketMQ".getBytes(StandardCharsets.UTF_8);
final Message message = provider.newMessageBuilder()
    .setTopic(topic)
    .setLiteTopic("{Lite_Topic_Name}") // Automatically created upon the first send
    .setBody(body)
    .build();

try {
    final SendReceipt sendReceipt = producer.send(message);
    log.info("Sent lite message successfully, messageId {}", sendReceipt.getMessageId());
} catch (Throwable t) {
    log.error("Failed to send lite message {}, please try again", message, t);
}

// Close the Producer before your business process exits or after you stop sending messages.
producer.close();

final String topic = "{Topic_Name}";                  // The name of the Lite Topic you created in the console
final String consumerGroup = "{Consumer_Group_Name}"; // The name of the consumer group you created in the console. Note: It must be bound to the correct Lite Topic.
final String accessKey = "{Access_Key}";              // The AccessKey of the role you created in the console
final String secretKey = "{Secret_Key}";              // The SecretKey of the role you created in the console
final String endpoints = "{EndPoints}";               // The cluster access point displayed in the console

final SessionCredentialsProvider sessionCredentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
final ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
    .setEndpoints(endpoints)
    .setCredentialProvider(sessionCredentialsProvider)
    .enableSsl(false)
    .build();

final LitePushConsumer litePushConsumer = provider.newLitePushConsumerBuilder()
    .setClientConfiguration(clientConfiguration)
    .setConsumerGroup(consumerGroup)
    .bindTopic(topic)
    .setMessageListener(messageView -> {
        // Business consumption code
        log.info("Consumed messageId {}", messageView.getMessageId());
        return ConsumeResult.SUCCESS;
    })
    .build();

try {
    litePushConsumer.subscribeLite("{Lite_Topic_Name}");
    // You can subscribe to more Lite Topics.
} catch (Throwable t) {
    log.error("Failed to subscribe lite topics, please try again", t);
}

// Close the Consumer before your business process exits.
litePushConsumer.close();