[jira] [Updated] (KAFKA-4932) Add UUID Serde

2017-03-22 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-4932: --- Description: I propose adding serializers and deserializers for the java.util.UUID class. I have many

[jira] [Updated] (KAFKA-4932) Add UUID Serde

2017-03-22 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-4932: --- Summary: Add UUID Serde (was: Add UUID Serdes) > Add UUID Serde > -- > >

[jira] [Created] (KAFKA-4932) Add UUID Serdes

2017-03-22 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-4932: -- Summary: Add UUID Serdes Key: KAFKA-4932 URL: https://issues.apache.org/jira/browse/KAFKA-4932 Project: Kafka Issue Type: Improvement Components: clien

[jira] [Resolved] (KAFKA-4257) Inconsistencies in 0.10.1 upgrade docs

2016-10-07 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas resolved KAFKA-4257. Resolution: Fixed Ismael's PR addresses these questions. > Inconsistencies in 0.10.1 upgrade docs

[jira] [Commented] (KAFKA-4257) Inconsistencies in 0.10.1 upgrade docs

2016-10-05 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548729#comment-15548729 ] Jeff Klukas commented on KAFKA-4257: The pull request definitely helps. Thanks for jum

[jira] [Created] (KAFKA-4257) Inconsistencies in 0.10.1 upgrade docs

2016-10-05 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-4257: -- Summary: Inconsistencies in 0.10.1 upgrade docs Key: KAFKA-4257 URL: https://issues.apache.org/jira/browse/KAFKA-4257 Project: Kafka Issue Type: Bug C

[jira] [Commented] (KAFKA-3895) Implement a default queue for expired messages

2016-09-29 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15533221#comment-15533221 ] Jeff Klukas commented on KAFKA-3895: It's not clear to me how the concepts here map on

[jira] [Updated] (KAFKA-3753) Add approximateNumEntries() to the StateStore interface for metrics reporting

2016-06-10 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-3753: --- Summary: Add approximateNumEntries() to the StateStore interface for metrics reporting (was: Add size

[jira] [Commented] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references

2016-06-10 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15325270#comment-15325270 ] Jeff Klukas commented on KAFKA-3801: I like concise code that you get from a static me

[jira] [Commented] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references

2016-06-09 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323718#comment-15323718 ] Jeff Klukas commented on KAFKA-3801: Let me give more context for the example. We have

[jira] [Commented] (KAFKA-3753) Add size() to the StateStore interface for metrics reporting

2016-06-09 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15323342#comment-15323342 ] Jeff Klukas commented on KAFKA-3753: I agree that {{size}} is a bit ambiguous. I'd exp

[jira] [Created] (KAFKA-3817) KTableRepartitionMap should handle null inputs

2016-06-09 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3817: -- Summary: KTableRepartitionMap should handle null inputs Key: KAFKA-3817 URL: https://issues.apache.org/jira/browse/KAFKA-3817 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3753) Metrics for StateStores

2016-06-09 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15322683#comment-15322683 ] Jeff Klukas commented on KAFKA-3753: Since there's refactoring going on right now with

[jira] [Created] (KAFKA-3801) Provide static serialize() and deserialize() for use as method references

2016-06-07 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3801: -- Summary: Provide static serialize() and deserialize() for use as method references Key: KAFKA-3801 URL: https://issues.apache.org/jira/browse/KAFKA-3801 Project: Kafka

[jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

2016-06-07 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318768#comment-15318768 ] Jeff Klukas commented on KAFKA-3711: I submitted a PR above to call {{originals()}} wh

[jira] [Commented] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

2016-06-07 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318546#comment-15318546 ] Jeff Klukas commented on KAFKA-3711: I would love to see this fixed as well. I'd also

[jira] [Commented] (KAFKA-3753) Metrics for StateStores

2016-06-07 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15318521#comment-15318521 ] Jeff Klukas commented on KAFKA-3753: It's good to know about MeteredKeyValueStore. And

[jira] [Created] (KAFKA-3753) Metrics for StateStores

2016-05-25 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3753: -- Summary: Metrics for StateStores Key: KAFKA-3753 URL: https://issues.apache.org/jira/browse/KAFKA-3753 Project: Kafka Issue Type: Improvement Component

[jira] [Updated] (KAFKA-3714) Allow users greater access to register custom streams metrics

2016-05-16 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Klukas updated KAFKA-3714: --- Issue Type: Improvement (was: Bug) > Allow users greater access to register custom streams metrics >

[jira] [Commented] (KAFKA-3715) Higher granularity streams metrics

2016-05-16 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15284706#comment-15284706 ] Jeff Klukas commented on KAFKA-3715: It would be interesting to work on this, but I wo

[jira] [Created] (KAFKA-3715) Higher granularity streams metrics

2016-05-16 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3715: -- Summary: Higher granularity streams metrics Key: KAFKA-3715 URL: https://issues.apache.org/jira/browse/KAFKA-3715 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-3714) Allow users greater access to register custom streams metrics

2016-05-16 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3714: -- Summary: Allow users greater access to register custom streams metrics Key: KAFKA-3714 URL: https://issues.apache.org/jira/browse/KAFKA-3714 Project: Kafka Issu

[jira] [Created] (KAFKA-3711) Allow configuration of MetricsReporter subclasses

2016-05-13 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3711: -- Summary: Allow configuration of MetricsReporter subclasses Key: KAFKA-3711 URL: https://issues.apache.org/jira/browse/KAFKA-3711 Project: Kafka Issue Type: Impro

[jira] [Created] (KAFKA-3701) Expose KafkaStreams metrics in public API

2016-05-11 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3701: -- Summary: Expose KafkaStreams metrics in public API Key: KAFKA-3701 URL: https://issues.apache.org/jira/browse/KAFKA-3701 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-3625) Move kafka-streams test fixtures into a published package

2016-04-26 Thread Jeff Klukas (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258338#comment-15258338 ] Jeff Klukas commented on KAFKA-3625: I would be willing to submit this patch if folks

[jira] [Created] (KAFKA-3625) Move kafka-streams test fixtures into a published package

2016-04-26 Thread Jeff Klukas (JIRA)
Jeff Klukas created KAFKA-3625: -- Summary: Move kafka-streams test fixtures into a published package Key: KAFKA-3625 URL: https://issues.apache.org/jira/browse/KAFKA-3625 Project: Kafka Issue Typ