---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28694/
---
Review request for kafka.
Bugs: KAFKA-1501
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/
---
(Updated Dec. 3, 2014, 11:02 p.m.)
Review request for kafka.
Bugs:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27430/#review63803
---
Ship it!
Ship It!
- Joel Koshy
On Dec. 3, 2014, 9:34 p.m.,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/
---
(Updated Dec. 4, 2014, 3:02 a.m.)
Review request for kafka.
Bugs: KAFKA-1650
On Dec. 3, 2014, 6:57 p.m., Guozhang Wang wrote:
core/src/main/scala/kafka/tools/MirrorMaker.scala, line 613
https://reviews.apache.org/r/25995/diff/7/?file=774325#file774325line613
I think there may be a race condition here, for example consider this
sequence:
1.
On Dec. 3, 2014, 6:57 p.m., Guozhang Wang wrote:
core/src/main/scala/kafka/tools/MirrorMaker.scala, line 613
https://reviews.apache.org/r/25995/diff/7/?file=774325#file774325line613
I think there may be a race condition here, for example consider this
sequence:
1.
On Dec. 3, 2014, 6:57 p.m., Guozhang Wang wrote:
core/src/main/scala/kafka/tools/MirrorMaker.scala, line 613
https://reviews.apache.org/r/25995/diff/7/?file=774325#file774325line613
I think there may be a race condition here, for example consider this
sequence:
1.
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28481/#review63757
---
core/src/main/scala/kafka/admin/AdminUtils.scala
On Nov. 25, 2014, 5:50 p.m., Joel Koshy wrote:
core/src/main/scala/kafka/server/ReplicaManager.scala, line 87
https://reviews.apache.org/r/27430/diff/2/?file=746549#file746549line87
In Kafka-1583 we had discussed renaming ReplicaManager to
ReplicatedLogManager or something like
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27430/
---
(Updated Dec. 3, 2014, 9:34 p.m.)
Review request for kafka.
Bugs: KAFKA-1720
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28481/
---
(Updated Dec. 3, 2014, 5:25 p.m.)
Review request for kafka.
Bugs: KAFKA-1792
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/#review63703
---
core/src/main/scala/kafka/tools/MirrorMaker.scala
[
https://issues.apache.org/jira/browse/KAFKA-1642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234297#comment-14234297
]
Bhavesh Mistry commented on KAFKA-1642:
---
[~ewencp],
1) I will posted toward
[
https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234415#comment-14234415
]
BalajiSeshadri commented on KAFKA-1476:
---
[~nehanarkhede] or [~junrao] or [~jkreps]
I'm just thinking instead of binding serialization with producer, another
option is to bind serializer/deserializer with
ProducerRecord/ConsumerRecord (please see the detail proposal below.)
The arguments for this option is:
A. A single producer could send different message
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/#review63878
---
Ship it!
Ship It!
- Guozhang Wang
On Dec. 4, 2014, 3:02 a.m.,
[
https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234496#comment-14234496
]
James Oliver commented on KAFKA-1790:
-
Thanks for the input, Joel. We'll keep that in
[
https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234530#comment-14234530
]
Jun Rao commented on KAFKA-1772:
It makes sense to have a single ClusterMetadata request
[
https://issues.apache.org/jira/browse/KAFKA-1790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234545#comment-14234545
]
Jun Rao commented on KAFKA-1790:
James,
Thanks for the explanation. It seems that not
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25995/
---
(Updated Dec. 4, 2014, 7:59 p.m.)
Review request for kafka.
Bugs: KAFKA-1650
[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234554#comment-14234554
]
Jiangjie Qin commented on KAFKA-1650:
-
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1650:
Attachment: KAFKA-1650_2014-12-04_11:59:07.patch
Mirror Maker could lose data on unclean shutdown.
[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234557#comment-14234557
]
Jiangjie Qin commented on KAFKA-1650:
-
[~junrao] Could you also help review the patch
[
https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234557#comment-14234557
]
Jiangjie Qin edited comment on KAFKA-1650 at 12/4/14 8:02 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234595#comment-14234595
]
Bhavesh Mistry commented on KAFKA-1788:
---
We also need to fix the Producer Close
[
https://issues.apache.org/jira/browse/KAFKA-727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234678#comment-14234678
]
lokesh Birla commented on KAFKA-727:
Hi,
Is this really fixed? I still see this issue
See https://builds.apache.org/job/Kafka-trunk/348/
--
[...truncated 827 lines...]
java.net.BindException: Address already in use
at sun.nio.ch.Net.bind(Native Method)
at
lokesh Birla created KAFKA-1806:
---
Summary: broker can still expose uncommitted data to a consumer
Key: KAFKA-1806
URL: https://issues.apache.org/jira/browse/KAFKA-1806
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234738#comment-14234738
]
Umesh Batra commented on KAFKA-1795:
Please ignore; I figured it out and leak was
[
https://issues.apache.org/jira/browse/KAFKA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Umesh Batra resolved KAFKA-1795.
Resolution: Not a Problem
The issue was with downstream post consumer component and not with Kafka.
[
https://issues.apache.org/jira/browse/KAFKA-1795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede closed KAFKA-1795.
OOME - high level kafka consumer
Key: KAFKA-1795
[
https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1476:
-
Assignee: (was: BalajiSeshadri)
Get a list of consumer groups
-
[
https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1476:
-
Assignee: Balaji Seshadri
Get a list of consumer groups
-
I agree that having the new ProducerK, V(KeySerializerK,
ValueSerializerV) interface would be useful.
People suggested cases where you want to mix and match serialization types.
The ByteArraySerializer is a no-op that would give the current behavior so
any odd case where you need to mix and match
[
https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234780#comment-14234780
]
Guozhang Wang commented on KAFKA-1755:
--
Here are my two cents:
1. At the end of the
[
https://issues.apache.org/jira/browse/KAFKA-1173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234816#comment-14234816
]
Joe Stein commented on KAFKA-1173:
--
[~ewencp] fell off my radar some will circle back on
Ewen Cheslack-Postava created KAFKA-1807:
Summary: Improve accuracy of ProducerPerformance target throughput
Key: KAFKA-1807
URL: https://issues.apache.org/jira/browse/KAFKA-1807
Project:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28735/
---
Review request for kafka.
Bugs: KAFKA-1807
[
https://issues.apache.org/jira/browse/KAFKA-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lam Thien Son updated KAFKA-1807:
-
Status: Patch Available (was: Open)
Improve accuracy of ProducerPerformance target throughput
[
https://issues.apache.org/jira/browse/KAFKA-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14234940#comment-14234940
]
Ewen Cheslack-Postava commented on KAFKA-1807:
--
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava updated KAFKA-1807:
-
Attachment: KAFKA-1807.patch
Improve accuracy of ProducerPerformance target
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28735/#review63953
---
Ship it!
Ship It!
- Neha Narkhede
On Dec. 5, 2014, 2:21 a.m.,
42 matches
Mail list logo