Updated on 2025-07-11 GMT+08:00

Configuring a RocketMQ Client

Suggestions on configuring a RocketMQ client.

Java Client Version

5.1.4 and later are recommended.

Unique ClientId

By default, ClientId combines the process ID, local IP address, and instance name. When two consumers in a consumer group are started in a process, their ClientIds are the same. As a result, some queues are repeatedly consumed and others cannot be consumed.

Recommended Setting

ClientId is generated with clientIP of a consumer. If different consumers share a clientIP at the same IP address, ClientId will be the same. You are advised to add the following code to manually set instanceName.
producer.setInstanceName(String.valueOf(System.nanoTime()))

Producer Exception Detection

Available in Java client 5.1.4 and later.

Enable exception detection on a client. When accessing a broker times out, the client can quickly switch to another broker for message production.

producer.setSendLatencyFaultEnable(true)