gchaoxue opened a new issue #690: Method 
DLedgerCommitLog.putMessages(MessageExtBatch) not implemented
URL: https://github.com/apache/rocketmq/issues/690
 
 
   Method 
`org.apache.rocketmq.store.dledger.DLedgerCommitLog.putMessages(MessageExtBatch)`
 is not implemented.
   
   I built the new dledger-implemented rocketmq from branch 
_store_with_dledger_ and wanted to try the new HA solution. But the client 
keeps getting "**MQBrokerException: CODE: 13  DESC: the message is illegal**" 
when I try to send a batch of messages. After debugging and making sure that 
there is nothing wrong with the client code, I read the server-side code and 
found that the batch-message putting method of `DledgerCommitLog` is under 
development and it is returning error code of `MESSAGE_ILLEGAL`.
   
   ```
   package org.apache.rocketmq.store.dledger;
   
   public class DLedgerCommitLog extends CommitLog {
       @Override
       public PutMessageResult putMessages(final MessageExtBatch 
messageExtBatch) {
           return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
       }
   }
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to