[jira] [Assigned] (KAFKA-2960) DelayedProduce may cause message lose during repeatly leader change

[ https://issues.apache.org/jira/browse/KAFKA-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-2960: --- Assignee: Jiangjie Qin > DelayedProduce may cause message lose during repeatly leader change

Jenkins build is back to normal : kafka-trunk-jdk7 #1094

See

[jira] [Commented] (KAFKA-2914) Kafka Connect Source connector for HBase

[ https://issues.apache.org/jira/browse/KAFKA-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15181927#comment-15181927 ] Andrew Purtell commented on KAFKA-2914: --- See HBASE-15320 > Kafka Connect Source connector for HBase

Re: kafka streams

Thanks Bill, The example code looks great! I will read through it, and am expecting your high-level examples already! Guozhang On Sat, Mar 5, 2016 at 12:39 PM, Bill Bejeck wrote: > Oops, forgot that little bit of information - >

Build failed in Jenkins: kafka-trunk-jdk8 #422

See Changes: [wangguoz] KAFKA-3233: expose consumer per-topic metrics -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu ubuntu

Re: [VOTE] Deprecating the old Scala producers for 0.10.0.0

+1. On Thu, Mar 3, 2016 at 9:26 PM, Grant Henke wrote: > +1 (non-binding) > > On Thu, Mar 3, 2016 at 9:39 PM, Ashish Singh wrote: > > > +1 (non-binding) > > > > On Thu, Mar 3, 2016 at 4:57 PM, Becket Qin wrote: > > > > > +1

[jira] [Commented] (KAFKA-3233) Per topic consumer metrics missing in new consumer's metrics reporter

[ https://issues.apache.org/jira/browse/KAFKA-3233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15181886#comment-15181886 ] ASF GitHub Bot commented on KAFKA-3233: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-3233) Per topic consumer metrics missing in new consumer's metrics reporter

[ https://issues.apache.org/jira/browse/KAFKA-3233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3233. -- Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull request 939

[GitHub] kafka pull request: KAFKA-3233: expose consumer per-topic metrics

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/939 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: kafka streams

Great. Mind sharing the draft or linking to the post if already published? Happy to review if that is useful. On Sat, Mar 5, 2016 at 12:07 PM, Bill Bejeck wrote: > All, > > I'm pretty excited about kafka-streams and I've written a blog (first of > 2-3) on the subject, and I'd

kafka streams

All, I'm pretty excited about kafka-streams and I've written a blog (first of 2-3) on the subject, and I'd thought I'd share. Thanks, Bill

[GitHub] kafka pull request: add some enhancements to MockConsumer

GitHub user fhussonnois opened a pull request: https://github.com/apache/kafka/pull/1016 add some enhancements to MockConsumer The MockConsumer class should support adding records concurrently. This allow to implement more complex test scenarios in which records are added