[I] How to use sql92 in rocketMQ to filter messages !maybe not a bug [rocketmq]

[via GitHub]

weixiaoming369 opened a new issue, #8631:
URL: https://github.com/apache/rocketmq/issues/8631

   ### Before Creating the Bug Report
   
   - [X] I found a bug, not just asking a question, which should be created in 
[GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [X] I have searched the [GitHub 
Issues](https://github.com/apache/rocketmq/issues) and [GitHub 
Discussions](https://github.com/apache/rocketmq/discussions)  of this 
repository and believe that this is not a duplicate.
   
   - [X] I have confirmed that this bug belongs to the current repository, not 
other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   win 11
   
   ### RocketMQ version
   
   4.9.4
   
   ### JDK Version
   
   1.8
   
   ### Describe the Bug
   
   I'm testing rocketMQ to enable sql92 to filter messages, but according to 
the official documentation steps and online references, I can't use sql92 to 
filter messages normally, it doesn't always report errors, but the frequency of 
errors is basically 100%
   
   ### Steps to Reproduce
   
   1、my pom 
    <dependency>
               <groupId>org.apache.rocketmq</groupId>
               <artifactId>rocketmq-client</artifactId>
               <version>4.9.4</version>
           </dependency>
   2、my rocketMQ window zip   rocketmq-all-4.9.4
   
![image](https://github.com/user-attachments/assets/04b3af0e-41a9-4f7b-8580-c3c6d6985d14)
   3、broker.conf and broker-a.properties and broker-a-s.properties 
   Both have added Inable Propelt = true
   4、this is my producer  test code
   
   
![image](https://github.com/user-attachments/assets/5bea9870-8f0c-40a8-b343-cbcdce0fe4ad)
   
   5、my consumer test code
   /**
        * 顺序消费
        * @throws Exception
        */
       public static void consumer_order() throws Exception {
           
           DefaultMQPushConsumer consumer = new 
DefaultMQPushConsumer("sql_consumer");
           consumer.setNamesrvAddr("127.0.0.1:9876");
           consumer.subscribe("test", MessageSelector.bySql("(TAGS IS NOT NULL 
AND TAGS IN ('Earth', 'Mars'))"
                   + "and country = 'China'"));
           consumer.setMessageModel(MessageModel.CLUSTERING);
           consumer.registerMessageListener(new MessageListenerOrderly() {
               AtomicLong consumerTimes = new AtomicLong(0);
               @Override
               public ConsumeOrderlyStatus consumeMessage(List<MessageExt> 
msgs, ConsumeOrderlyContext consumeOrderlyContext) {
                   for (MessageExt msg : msgs) {
                       this.consumerTimes.incrementAndGet();
                       try {
                           System.err.printf("%s receiveMessage : %s%n", 
Thread.currentThread().getName(),
                                   new String(msg.getBody(), 
RemotingHelper.DEFAULT_CHARSET));
                       } catch (UnsupportedEncodingException e) {
                           throw new RuntimeException(e);
                       }
                       if (this.consumerTimes.get() % 2 == 0) {
                           return ConsumeOrderlyStatus.SUCCESS;
                       } else if (this.consumerTimes.get() % 5 == 0) {
                           
consumeOrderlyContext.setSuspendCurrentQueueTimeMillis(3000);
                           return 
ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
                       }
                       return ConsumeOrderlyStatus.SUCCESS;
                   }
                   return null;
               }
           });
           consumer.start();
           System.out.printf("consumer started %n");
       }
   6、this is err info messages when boot test
   
   
![image](https://github.com/user-attachments/assets/79e6d7a7-0f46-4de2-8e91-031b8073aca4)
   
   
   ### What Did You Expect to See?
   
   11111111111111111111
   
   ### What Did You See Instead?
   
   1111111111111111
   
   ### Additional Context
   
   
![image](https://github.com/user-attachments/assets/f46eb3ca-4249-4d4c-917b-71b0351bae5c)
   
   
![22](https://github.com/user-attachments/assets/7caf3e4b-7c8b-49ce-a216-2fb0979a0226)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org