[
https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693676#comment-14693676
]
Eugene Miretsky commented on KAFKA-1683:
My apologies, didn't word the question
[
https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693676#comment-14693676
]
Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:36 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693676#comment-14693676
]
Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:39 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693676#comment-14693676
]
Eugene Miretsky edited comment on KAFKA-1683 at 8/12/15 3:40 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-1893 started by Ashish K Singh.
-
Allow regex subscriptions in the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-1893:
--
Status: Patch Available (was: In Progress)
Allow regex subscriptions in the new consumer
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/133
KAFKA-2429: Add annotations to mark classes as stable/unstable
This also marks the consumer as unstable to show an example of using these
annotations.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/KAFKA-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694170#comment-14694170
]
ASF GitHub Bot commented on KAFKA-2429:
---
GitHub user ewencp opened a pull request:
On July 29, 2015, 6:35 p.m., Gwen Shapira wrote:
core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala, lines 237-242
https://reviews.apache.org/r/28096/diff/4/?file=991387#file991387line237
These look identical - copy/paste error?
Ashish Singh wrote:
Not really. There
[
https://issues.apache.org/jira/browse/KAFKA-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2429 started by Ewen Cheslack-Postava.
Add annotations to mark classes as stable/unstable
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28096/
---
(Updated Aug. 12, 2015, 9:21 p.m.)
Review request for kafka, Gwen Shapira,
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694190#comment-14694190
]
Ashish K Singh commented on KAFKA-313:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2429:
Resolution: Fixed
Fix Version/s: 0.8.3
Status: Resolved (was: Patch Available)
[
https://issues.apache.org/jira/browse/KAFKA-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694249#comment-14694249
]
ASF GitHub Bot commented on KAFKA-2429:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694393#comment-14694393
]
Ismael Juma commented on KAFKA-2425:
Requiring a different branch is annoying.
[
https://issues.apache.org/jira/browse/KAFKA-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-2300:
-
Resolution: Fixed
Status: Resolved (was: Patch Available)
Issue resolved by pull request
[
https://issues.apache.org/jira/browse/KAFKA-2300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694208#comment-14694208
]
ASF GitHub Bot commented on KAFKA-2300:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/102
---
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
[
https://issues.apache.org/jira/browse/KAFKA-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-2429:
-
Status: Patch Available (was: In Progress)
Add annotations to mark classes as
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/131
---
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
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694383#comment-14694383
]
Ismael Juma commented on KAFKA-2367:
I think using Avro (as suggested by [~gwenshap])
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-313:
-
Attachment: KAFKA-313_2015-08-12_14:21:32.patch
Add JSON/CSV output and looping options to
[
https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-313:
-
Status: Patch Available (was: In Progress)
Add JSON/CSV output and looping options to
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/133
---
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
Hi Team Kafka,
Ewen just added stability annotations to Apache Kafka (KAFKA-2429).
In the same PR, we marked the new Consumer API as unstable since we are
still actively iterating on them. The goal is to mark them as evolving
before the next release and after one release to validate them, we
Ewen Cheslack-Postava created KAFKA-2429:
Summary: Add annotations to mark classes as stable/unstable
Key: KAFKA-2429
URL: https://issues.apache.org/jira/browse/KAFKA-2429
Project: Kafka
Yeah. Jun used to send out table-summary of backlogs with reviews before
KIP meeting, we can continue to do that.
Also we used to have a dashboard for replication development tracking,
Neha/Jun/Joel do you remember how to setup sth. similar?
Guozhang
On Tue, Aug 11, 2015 at 10:31 PM, Jiangjie
[
https://issues.apache.org/jira/browse/KAFKA-2367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694407#comment-14694407
]
Gwen Shapira commented on KAFKA-2367:
-
I'm a strong +1 on using Avro instead of
This is a great idea!
I do question the classifications a bit. @stable seams unreasonable as
Kafka has not has a major release yet. I have typically thought of Kafka
releases as 0.{major}.{minor}.{maintenance}. For instance 0.8.3 coming up
has a significant amount of change. Though Kafka's
Yeah, I agree that your description matches reality better :)
By document do you have any suggestions where? The interface itself has
documentation. Were you thinking Wiki?
On Wed, Aug 12, 2015 at 3:48 PM, Grant Henke ghe...@cloudera.com wrote:
This is a great idea!
I do question the
On Aug. 6, 2015, 4:17 p.m., Jun Rao wrote:
A few more comments.
We need to be careful with sensors at the client-id level. Clients can come
and go (e.g. console consumer). We probably don't want to hold sensors that
are not longer actively used since it takes memory. So, we will
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1782.
--
Resolution: Fixed
Issue resolved by pull request 135
[https://github.com/apache/kafka/pull/135]
GitHub user becketqin opened a pull request:
https://github.com/apache/kafka/pull/134
KAFKA-2389: remove commit type from new consumer.
A shot to remove commit type from new consumer. The coordinator constructor
takes a default offset commit callback mainly for testing purpose.
[
https://issues.apache.org/jira/browse/KAFKA-2389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694519#comment-14694519
]
ASF GitHub Bot commented on KAFKA-2389:
---
GitHub user becketqin opened a pull
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/#review95216
---
core/src/main/scala/kafka/server/ClientQuotaManager.scala (line
[
https://issues.apache.org/jira/browse/KAFKA-2336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694558#comment-14694558
]
Joel Koshy commented on KAFKA-2336:
---
Sorry I should not have assigned it to myself
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694494#comment-14694494
]
Gwen Shapira commented on KAFKA-2425:
-
I guess I'm not imagining how it works
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/135
---
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
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 13, 2015, 4:24 a.m.)
Review request for kafka, Joel Koshy and
Good annotations. I can see a few future usages :)
Jiangjie (Becket) Qin
On Wed, Aug 12, 2015 at 3:05 PM, Gwen Shapira g...@confluent.io wrote:
Hi Team Kafka,
Ewen just added stability annotations to Apache Kafka (KAFKA-2429).
In the same PR, we marked the new Consumer API as unstable
Hi Gwen,
Nice to see this. There is no deprecation cycle for breakages?
Ismael
On Wed, Aug 12, 2015 at 11:05 PM, Gwen Shapira g...@confluent.io wrote:
Hi Team Kafka,
Ewen just added stability annotations to Apache Kafka (KAFKA-2429).
In the same PR, we marked the new Consumer API as
On Aug. 11, 2015, 8:49 p.m., Jason Gustafson wrote:
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java,
line 302
https://reviews.apache.org/r/36858/diff/4/?file=1037078#file1037078line302
Can we make this value greater than sessionTimeoutMs (which is
[
https://issues.apache.org/jira/browse/KAFKA-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke reassigned KAFKA-2244:
--
Assignee: Grant Henke
Document Kafka metrics configuration properties
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2084:
-
Attachment: KAFKA-2084_2015-08-12_21:24:07.patch
byte rate metrics per client ID
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694663#comment-14694663
]
Aditya A Auradkar commented on KAFKA-2084:
--
Updated reviewboard
GitHub user ewencp opened a pull request:
https://github.com/apache/kafka/pull/135
KAFKA-Junit3 Misusage
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ewencp/kafka kafka-1782-junit3-misusage
Alternatively you can review and
On June 17, 2015, 4:40 p.m., Joel Koshy wrote:
core/src/main/scala/kafka/server/ClientQuotaMetrics.scala, line 1
https://reviews.apache.org/r/33049/diff/15/?file=983845#file983845line1
Why was MockTime moved from test to main?
Aditya Auradkar wrote:
Because I need to depend
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694602#comment-14694602
]
Guozhang Wang commented on KAFKA-1782:
--
[~apakulov] Thanks for the patch, [~ewencp]
On Tue, Aug 11, 2015 at 11:29 PM, Jiangjie Qin j...@linkedin.com.invalid
wrote:
Ewen,
Thanks for the explanation.
For (1), I am more concerned about the failure case instead of normal case.
What if a consumer somehow was kick out of a group but is still consuming
and committing offsets?
Ismael Juma created KAFKA-2423:
--
Summary: Introduce Scalastyle
Key: KAFKA-2423
URL: https://issues.apache.org/jira/browse/KAFKA-2423
Project: Kafka
Issue Type: Improvement
Reporter:
On Wed, Aug 12, 2015 at 1:29 AM, Gwen Shapira g...@confluent.io wrote:
+1 on not breaking git blame
-1 on rewriting Kafka in Java
+1 on upping our Scala game (as Ismael pointed out)
I filed a couple of JIRAs, and I'll look at introducing Scalastyle once
some of the bigger patches/PRs are
[
https://issues.apache.org/jira/browse/KAFKA-2364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693167#comment-14693167
]
Ismael Juma commented on KAFKA-2364:
[~anshbansal], the consensus was that moving to
On Tue, Aug 11, 2015 at 10:15 PM, Jiangjie Qin j...@linkedin.com.invalid
wrote:
Hi Jason,
Thanks for writing this up. It would be useful to generalize the group
concept. I have a few questions below.
1. In old consumer actually the partition assignment are done by consumers
themselves. We
On Wed, Aug 12, 2015 at 1:23 AM, Jason Gustafson ja...@confluent.io wrote:
Can the java code be indented without affecting the results of git blame?
If not, then I'd vote to leave it as it is.
Nope.
Ismael
Ismael Juma created KAFKA-2424:
--
Summary: Consider introducing lint-like tool for Scala
Key: KAFKA-2424
URL: https://issues.apache.org/jira/browse/KAFKA-2424
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-2424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-2424:
---
Labels: newbie (was: )
Consider introducing lint-like tool for Scala
Hi Gwen,
I filed KAFKA-2425 as KAFKA-2364 is about improving the website
documentation. Aseem Bansal seemed interested in helping us with the move
so I pinged him in the issue.
Best,
Ismael
On Wed, Aug 12, 2015 at 1:51 AM, Gwen Shapira g...@confluent.io wrote:
Ah, there is already a JIRA in
[
https://issues.apache.org/jira/browse/KAFKA-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693242#comment-14693242
]
Artem Kirillov commented on KAFKA-2165:
---
We experience the same issue on our
Harish Seshadri created KAFKA-2427:
--
Summary: Error writing to highwatermark file
Key: KAFKA-2427
URL: https://issues.apache.org/jira/browse/KAFKA-2427
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693330#comment-14693330
]
Manikumar Reddy commented on KAFKA-2425:
You can find the docs here :
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693182#comment-14693182
]
Ismael Juma commented on KAFKA-2425:
[~anshbansal], are you interested in attempting
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693213#comment-14693213
]
PC edited comment on KAFKA-2078 at 8/12/15 9:30 AM:
Here is an update
[
https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693213#comment-14693213
]
PC commented on KAFKA-2078:
---
Here is an update on appears to cause this problem:
Pumping 4
FYI, I created a tiny trivial patch to address a typo in the web site
(KAFKA-2418), so maybe you can review it and eventually commit before
moving to github. ;)
Cheers,
Eddie
Em 12/08/2015 06:01, Ismael Juma ism...@juma.me.uk escreveu:
Hi Gwen,
I filed KAFKA-2425 as KAFKA-2364 is about
Mikaël Cluseau created KAFKA-2426:
-
Summary: A Kafka node tries to connect to itself through its
advertised hostname
Key: KAFKA-2426
URL: https://issues.apache.org/jira/browse/KAFKA-2426
Project:
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693316#comment-14693316
]
Aseem Bansal commented on KAFKA-2425:
-
Yes I am interested. But how to do that. I mean
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693330#comment-14693330
]
Manikumar Reddy edited comment on KAFKA-2425 at 8/12/15 11:24 AM:
[
https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693859#comment-14693859
]
David Jacot commented on KAFKA-2073:
[~abiletskyi] Are you still working on this one?
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693855#comment-14693855
]
David Jacot commented on KAFKA-2071:
[~gwenshap] Could you review this one when you
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693544#comment-14693544
]
Manikumar Reddy commented on KAFKA-2425:
Issue Type can be simple Bug. SVN-GIT
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693505#comment-14693505
]
Aseem Bansal edited comment on KAFKA-2425 at 8/12/15 1:54 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693505#comment-14693505
]
Aseem Bansal commented on KAFKA-2425:
-
The Infra ticket has fields Git Notification
[
https://issues.apache.org/jira/browse/KAFKA-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694010#comment-14694010
]
Gwen Shapira commented on KAFKA-2418:
-
Committed! Our docs look better now :)
Thanks
[
https://issues.apache.org/jira/browse/KAFKA-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2418:
Resolution: Fixed
Reviewer: Gwen Shapira
Status: Resolved (was: Patch Available)
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:02 p.m.)
Review request for kafka, Joel Koshy and
On Aug. 12, 2015, 12:34 a.m., Jun Rao wrote:
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java, lines
131-150
https://reviews.apache.org/r/33049/diff/21/?file=1037164#file1037164line131
I think the comment can be a simpler. Basically, if O is the observed
rate
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:03 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2084:
-
Attachment: KAFKA-2084_2015-08-12_12:02:33.patch
byte rate metrics per client ID
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694017#comment-14694017
]
Aditya A Auradkar commented on KAFKA-2084:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:04 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2084:
-
Attachment: KAFKA-2084_2015-08-12_12:04:51.patch
byte rate metrics per client ID
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694021#comment-14694021
]
Aditya A Auradkar commented on KAFKA-2084:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:05 p.m.)
Review request for kafka, Joel Koshy and
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:08 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2084:
-
Attachment: KAFKA-2084_2015-08-12_12:08:17.patch
byte rate metrics per client ID
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694023#comment-14694023
]
Aditya A Auradkar commented on KAFKA-2084:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated Aug. 12, 2015, 7:09 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14694034#comment-14694034
]
Gwen Shapira commented on KAFKA-2425:
-
Wouldn't a new branch mean that we can't push
On Aug. 12, 2015, 12:42 a.m., Jun Rao wrote:
core/src/main/scala/kafka/server/KafkaConfig.scala, line 419
https://reviews.apache.org/r/33049/diff/21/?file=1037170#file1037170line419
I am still not sure that I see the value of the delay factor. If one
wants to be a bit
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayuresh Gharat updated KAFKA-2120:
---
Attachment: KAFKA-2120_2015-08-12_10:59:09.patch
Add a request timeout to NetworkClient
[
https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693951#comment-14693951
]
Mayuresh Gharat commented on KAFKA-2120:
Updated reviewboard
Hey Ewen,
Onur and I discussed this a little bit more. And we are still worrying
about passing all the metadata of all consumers around.
Let's say I have a cluster has 10,000 topics, the average topic name length
is 10 bytes. In this case, the opaque metadata will have 10 * 10,000 =
100KB for
[
https://issues.apache.org/jira/browse/KAFKA-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ben Stopford reassigned KAFKA-2015:
---
Assignee: Ben Stopford (was: Guozhang Wang)
Enable ConsoleConsumer to use new consumer
+1 about rewriting to Java (in a year or more).
+1 about upping Scala use in the meanwhile
+1 about using Gradle instead of Maven or SBT.
Eddie
On Wed, Aug 12, 2015 at 5:26 AM, Ismael Juma ism...@juma.me.uk wrote:
On Wed, Aug 12, 2015 at 1:29 AM, Gwen Shapira g...@confluent.io wrote:
+1 on
[
https://issues.apache.org/jira/browse/KAFKA-2418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693984#comment-14693984
]
Edward Ribeiro commented on KAFKA-2418:
---
Hi folks, if you have any free time could
[
https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-2072:
--
Assignee: David Jacot
Add StopReplica request/response to o.a.k.common.requests and replace
Mayuresh Gharat created KAFKA-2428:
--
Summary: Add sanity test in kafkaConsumer for the timeouts. This
is a followup ticket for Kafka-2120
Key: KAFKA-2428
URL: https://issues.apache.org/jira/browse/KAFKA-2428
On Aug. 11, 2015, 8:49 p.m., Jason Gustafson wrote:
clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java,
line 302
https://reviews.apache.org/r/36858/diff/4/?file=1037078#file1037078line302
Can we make this value greater than sessionTimeoutMs (which is
[
https://issues.apache.org/jira/browse/KAFKA-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14693874#comment-14693874
]
Gwen Shapira commented on KAFKA-2071:
-
Its on my review queue, so I definitely will.
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36858/
---
(Updated Aug. 12, 2015, 5:59 p.m.)
Review request for kafka.
Bugs:
1 - 100 of 102 matches
Mail list logo
