[ https://issues.apache.org/jira/browse/KAFKA-385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13434602#comment-13434602 ]
Jay Kreps commented on KAFKA-385: --------------------------------- 1. Can we make the reporters pluggable? We shouldn't hard code those, you should just give something like metrics.reporters=com.xyz.MyReporter, com.xyz.YourReporter 2. Please remove the reference to scala class names from the logging (e.g. DelayedProduce) 3. How are you measuring the performance impact of the change you made to synchronization? 4. It would be good to cut-and-paste the scala timer class they provide in the scala wrapper. That is really nice. 5. Size. I think the overhead is the following: 8 byte pointer to the value 12 byte object header 8 byte value Total: 28 bytes This is too much memory for something that should just be monitoring. I think we should not do per-key histograms. > RequestPurgatory enhancements - expire/checkSatisfy issue; add jmx beans > ------------------------------------------------------------------------ > > Key: KAFKA-385 > URL: https://issues.apache.org/jira/browse/KAFKA-385 > Project: Kafka > Issue Type: Bug > Reporter: Joel Koshy > Assignee: Joel Koshy > Labels: bugs > Fix For: 0.8 > > Attachments: example_dashboard.jpg, graphite_explorer.jpg, > KAFKA-385-v1.patch, KAFKA-385-v2.patch > > > As discussed in KAFKA-353: > 1 - There is potential for a client-side race condition in the > implementations of expire and checkSatisfied. We can just synchronize on the > DelayedItem. > 2 - Would be good to add jmx beans to facilitate monitoring RequestPurgatory > stats. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira