[GitHub] [skywalking-java] zhyyu commented on pull request #361: rocketmq scenario

[GitBox <gi...@apache.org>]

zhyyu commented on PR #361:
URL: https://github.com/apache/skywalking-java/pull/361#issuecomment-1286578668

   This scenario is unfinished. I meet a weird problem and can not figure it out for a longtime. The provider segment successfully report to mock collector, but the consumer segment missed.
   
   I run the run.sh debug mode,
   
   the secnario.out shows that rocketmq conumser success.
   ```
   Provider Started.
   Fri Oct 21 07:21:53 UTC 2022 send msg: SendResult [sendStatus=SEND_OK, msgId=7F0000010030351E414E6893BBFA0000, offsetMsgId=AC17000300002A9F0000000000000000, messageQueue=MessageQueue [topic=TopicTest, brokerName=broker, queueId=2], queueOffset=0]
   Consumer Started.
   ConsumeMessageThread_please_rename_unique_group_name_1 Receive New Messages: Hello RocketMQ sendMsg Fri Oct 21 07:21:51 UTC 2022 
   ```
   
   bug actualData.yaml do not exit consumer segment
   
   ```
   segmentItems:
   - serviceName: rocketmq-scenario
     segmentSize: 2
     segments:
     - segmentId: e20e9a5ec93e49858ca254713a3d370e.37.16663369109610000
       spans:
       - operationName: HEAD:/rocketmq-scenario/case/healthCheck
         parentSpanId: -1
         spanId: 0
         spanLayer: Http
         startTime: 1666336910980
         endTime: 1666336911321
         componentId: 1
         isError: false
         spanType: Entry
         peer: ''
         skipAnalysis: false
         tags:
         - {key: url, value: 'http://localhost:8080/rocketmq-scenario/case/healthCheck'}
         - {key: http.method, value: HEAD}
         - {key: http.status_code, value: '200'}
     - segmentId: e20e9a5ec93e49858ca254713a3d370e.38.16663369113630000
       spans:
       - operationName: RocketMQ/TopicTest/Producer
         parentSpanId: 0
         spanId: 1
         spanLayer: MQ
         startTime: 1666336912425
         endTime: 1666336913135
         componentId: 38
         isError: false
         spanType: Exit
         peer: namesrv:9876
         skipAnalysis: false
         tags:
         - {key: mq.broker, value: '172.23.0.3:10911'}
         - {key: mq.topic, value: TopicTest}
       - operationName: GET:/rocketmq-scenario/case/rocketmq-scenario
         parentSpanId: -1
         spanId: 0
         spanLayer: Http
         startTime: 1666336911363
         endTime: 1666336913185
         componentId: 1
         isError: false
         spanType: Entry
         peer: ''
         skipAnalysis: false
         tags:
         - {key: url, value: 'http://localhost:8080/rocketmq-scenario/case/rocketmq-scenario'}
         - {key: http.method, value: GET}
         - {key: http.status_code, value: '200'}
   meterItems:
   - serviceName: rocketmq-scenario
     meterSize: 5
     meters:
     - meterId:
         name: thread_pool
         tags:
         - {name: metric_type, value: active_size}
         - {name: pool_name, value: tomcat_execute_pool}
       singleValue: 0.0
     - meterId:
         name: thread_pool
         tags:
         - {name: metric_type, value: queue_size}
         - {name: pool_name, value: tomcat_execute_pool}
       singleValue: 0.0
     - meterId:
         name: thread_pool
         tags:
         - {name: metric_type, value: pool_size}
         - {name: pool_name, value: tomcat_execute_pool}
       singleValue: 10.0
     - meterId:
         name: thread_pool
         tags:
         - {name: metric_type, value: core_pool_size}
         - {name: pool_name, value: tomcat_execute_pool}
       singleValue: 10.0
     - meterId:
         name: thread_pool
         tags:
         - {name: metric_type, value: max_pool_size}
         - {name: pool_name, value: tomcat_execute_pool}
       singleValue: 200.0
   logItems: []
   
   ```


-- 
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: notifications-unsubscribe@skywalking.apache.org

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