equanz commented on PR #18254:
URL: https://github.com/apache/pulsar/pull/18254#issuecomment-1311168182

   For example, when enabling `aggregatePublisherStatsByProducerName` in the 
v2.10.1 server
   
   ```
   % grep 'aggregatePublisherStatsByProducerName' conf/standalone.conf
   aggregatePublisherStatsByProducerName=true
   ```
   
   and create the partitioned producer to the partitioned topic by the v2.8.4 
client,
   
   ```
    ./bin/pulsar-perf produce -r 1 -s 10 persistent://public/default/pt
   ...
   11:28:34.053 [main] INFO  org.apache.pulsar.testclient.PerformanceProducer - 
Starting Pulsar perf producer with config: {
   ...
     "producerName" : null,
   ...
   11:28:34.969 [pulsar-client-io-2-1] INFO  
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://public/default/pt-partition-0] [standalone-0-1] Created producer 
on cnx [id: 0x0e5ab2e4, L:/127.0.0.1:49990 - R:localhost/127.0.0.1:6650]
   11:28:34.992 [pulsar-client-io-2-1] INFO  
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://public/default/pt-partition-1] [standalone-0-0] Created producer 
on cnx [id: 0x32a3290d, L:/127.0.0.1:49989 - R:localhost/127.0.0.1:6650]
   ...
   ```
   
   then the broker returns partitioned topic stats like the one below.
   
   ```
   % ./bin/pulsar-admin topics partitioned-stats persistent://public/default/pt
   ...
     "publishers" : [ {
       "msgRateIn" : 0.0,
       "msgThroughputIn" : 0.0,
       "averageMsgSize" : 0.0,
       "chunkedMessageRate" : 0.0,
       "producerId" : 0,
       "supportsPartialProducer" : false
     } ],
   ...
   ```
   
   However, when running with your fixes on the server side and creating a 
producer to a partitioned topic by the v2.8.4 client,
   
   ```
   % ./bin/pulsar-perf produce -r 1 -s 10 persistent://public/default/pt
   ...
     "producerName" : null,
   ...
   11:30:37.289 [pulsar-client-io-2-1] INFO  
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://public/default/pt-partition-1] [standalone-0-1] Created producer 
on cnx [id: 0x393b0652, L:/127.0.0.1:50035 - R:localhost/127.0.0.1:6650]
   11:30:37.307 [pulsar-client-io-2-1] INFO  
org.apache.pulsar.client.impl.ProducerImpl - 
[persistent://public/default/pt-partition-0] [standalone-0-0] Created producer 
on cnx [id: 0x9b73aa95, L:/127.0.0.1:50034 - R:localhost/127.0.0.1:6650]
   ...
   ```
   
   then the broker returns partitioned topic stats like the one below. As you 
can see, publishers can't be aggregated by producerName even if the partitioned 
producer is alone in the partitioned topic. It is breaking changes. Is it 
allowed on this project?
   
   ```
   % ./bin/pulsar-admin topics partitioned-stats persistent://public/default/pt
   ...
     "publishers" : [ {
       "msgRateIn" : 0.0,
       "msgThroughputIn" : 0.0,
       "averageMsgSize" : 0.0,
       "chunkedMessageRate" : 0.0,
       "producerId" : 0,
       "supportsPartialProducer" : true,
       "producerName" : "standalone-0-1"
     }, {
       "msgRateIn" : 0.0,
       "msgThroughputIn" : 0.0,
       "averageMsgSize" : 0.0,
       "chunkedMessageRate" : 0.0,
       "producerId" : 0,
       "supportsPartialProducer" : true,
       "producerName" : "standalone-0-0"
     } ],
   ...
   ```


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to