How about making UUID.randomUUID.toString() the default in KeyedMessage
instead of null if not supplied
def this(topic: String, message: V) = this(topic, UUID.randomUUID.toString(),
message)
and if you want the random refresh behavior then pass in "*" on the
KeyedMessage construction which we can
Issue Subscription
Filter: outstanding kafka patches (67 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-1068 OfflinePartitionCount metrics may be incorrect after the controller
failover
https://issues.apache.org/jira/browse/KAFK
[
https://issues.apache.org/jira/browse/KAFKA-1068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13781963#comment-13781963
]
Neha Narkhede commented on KAFKA-1068:
--
Gave a Ship It on the rb. Thanks for trying o
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/14399/#review26489
---
Ship it!
Ship It!
- Neha Narkhede
On Sept. 29, 2013, 11:25 p.m.,
[
https://issues.apache.org/jira/browse/KAFKA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1065.
Resolution: Duplicate
Close this since it duplicates kafka-1008.
> IO exception on windows when high throu
[
https://issues.apache.org/jira/browse/KAFKA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-1065 started by Jun Rao.
> IO exception on windows when high throughput of messages
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-1065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13781721#comment-13781721
]
Carl Austin commented on KAFKA-1065:
Sorry for the slow reply, I've only just got arou
