[ 
https://issues.apache.org/jira/browse/KAFKA-622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13505934#comment-13505934
 ] 

Neha Narkhede commented on KAFKA-622:
-------------------------------------

v3 looks much better and almost ready for check in. Few minor cleanup comments -

9. Minor naming convention suggestion - Probably better to rename 
ClientIdTopicPartition to ClientIdAndPartition or ClientIdAndTopicPartition
10. ProducerPool Minor documentation nitpick - The API docs for 
createSyncProducer doesn't match the commenting style for documenting APIs. We 
use C style comments while this patch has added C++ style comments.
11. SimpleConsumerPerformance - Remove unused import 
FetchRequestAndResponseStats
12. BrokerPartitionInfo - Not introduced by your patch, but will be good to 
fix. Typo in the name of the param. Change it to topics instead of topic
13.1 Producer - Again not introduced by your patch, just happened to notice it 
right now. Typo in the name of the param in send API docs. It says producerData 
now but should be messages
13.2 Minor nitpick - Rest of the metrics classes have name as their constructor 
argument, except ProducerTopicMetrics which says tuple and its not a tuple.
14. SyncProducerConfig - Elsewhere, we don't use camel case for config names. 
Probably best to change it to clientid like in ConsumerConfig
15. What happened to Topic.scala ?

7. For now, it seems that the messages rate, both per topic and global should 
suffice. We can, however, think about how/if the aggregation metrics for fetch 
response rate and size makes sense at the ZookeeperConsumerConnector level. But 
I d
on't think we should hold up this patch for it. Please can you file a JIRA to 
track that ?


                
> Create mbeans per client 
> -------------------------
>
>                 Key: KAFKA-622
>                 URL: https://issues.apache.org/jira/browse/KAFKA-622
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.8
>            Reporter: Swapnil Ghike
>            Assignee: Swapnil Ghike
>            Priority: Blocker
>              Labels: bugs, improvement
>             Fix For: 0.8
>
>         Attachments: kafka-622-v1.patch, kafka-622-v2.patch, 
> kafka-622-v3.patch
>
>
> Currently we create one mbean of each type for a given mbean server, 
> regardless of the number of clients. We should create MBeans per client for 
> both producer and consumer. To do that we need to introduce clientId in mbean 
> names.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to