brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 deleteWhen = 04 fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH unitName = DefaultUnit namesrvAddr = 192.168.0.1:9876 listenPort = 10911 listenPort = 9876 brokerAddress = 192.168.0.1:10911;192.168.0.2:10911 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>3.6.2</version> </dependency> import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.common.message.Message; public class RocketMQProducer { public static void main(String[] args) throws Exception { DefaultMQProducer producer = new DefaultMQProducer("producer_group"); producer.setNamesrvAddr("192.168.0.1:9876"); producer.start(); Message message = new Message("topic", "tag", "Hello, RocketMQ".getBytes()); producer.send(message); producer.shutdown(); } } `mvn clean package` `java -cp your-project.jar com.your.package.RocketMQProducer`