[
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