[
https://issues.apache.org/jira/browse/KAFKA-930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829130#comment-13829130
]
Sriram Subramanian commented on KAFKA-930:
--
Updated reviewboard
Guozhang Wang created KAFKA-1139:
Summary: Topic data change handling callback should not call
syncedRebalance directly
Key: KAFKA-1139
URL: https://issues.apache.org/jira/browse/KAFKA-1139
Project:
[
https://issues.apache.org/jira/browse/KAFKA-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829244#comment-13829244
]
Guozhang Wang commented on KAFKA-1103:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829078#comment-13829078
]
Jun Rao commented on KAFKA-1103:
The latest patch reverted some of the old commits. Could
[
https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829263#comment-13829263
]
Guozhang Wang commented on KAFKA-404:
-
Thanks for the patch, a few comments:
1. val
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15711/
---
(Updated Nov. 21, 2013, 5:42 p.m.)
Review request for kafka.
Bugs: KAFKA-930
[
https://issues.apache.org/jira/browse/KAFKA-1137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy resolved KAFKA-1137.
---
Resolution: Invalid
Closing - this behavior is documented here:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15659/
---
(Updated Nov. 21, 2013, 7:22 p.m.)
Review request for kafka.
Summary
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15711/#review29242
---
core/src/main/scala/kafka/controller/KafkaController.scala
[
https://issues.apache.org/jira/browse/KAFKA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829077#comment-13829077
]
Jun Rao commented on KAFKA-1138:
Do you think
On Nov. 20, 2013, 6:30 p.m., Jun Rao wrote:
core/src/main/scala/kafka/controller/KafkaController.scala, lines 745-746
https://reviews.apache.org/r/15711/diff/3/?file=388714#file388714line745
Could we rename updateZk to sth like isTriggeredByCommandLine?
Sriram Subramanian wrote:
On Nov. 20, 2013, 6:30 p.m., Jun Rao wrote:
core/src/main/scala/kafka/server/KafkaConfig.scala, lines 236-239
https://reviews.apache.org/r/15711/diff/3/?file=388715#file388715line236
I am wondering if this config is really necessary. Wouldn't it be
simpler to always do the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/15711/#review29240
---
core/src/main/scala/kafka/controller/KafkaController.scala
Issue Subscription
Filter: outstanding kafka patches (75 issues)
The list of outstanding kafka patches
Subscriber: kafka-mailing-list
Key Summary
KAFKA-1136 Add subAppend in Log4jAppender for generic usage
https://issues.apache.org/jira/browse/KAFKA-1136
KAFKA-1133 LICENSE
[
https://issues.apache.org/jira/browse/KAFKA-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1103:
-
Attachment: KAFKA-1103_2013-11-21_11:22:04.patch
Consumer uses two zkclients
Guozhang Wang created KAFKA-1140:
Summary: Move the decoding logic from ConsumerIterator.makeNext to
next
Key: KAFKA-1140
URL: https://issues.apache.org/jira/browse/KAFKA-1140
Project: Kafka
On Nov. 21, 2013, 3:41 a.m., Swapnil Ghike wrote:
core/src/main/scala/kafka/controller/KafkaController.scala, line 926
https://reviews.apache.org/r/15711/diff/3/?file=388714#file388714line926
rename to topicPartitionsNotLedByPreferredReplica?
PreferredReplica cannot lead multiple
[
https://issues.apache.org/jira/browse/KAFKA-1140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1140:
--
Fix Version/s: 0.8.1
Move the decoding logic from ConsumerIterator.makeNext to next
[
https://issues.apache.org/jira/browse/KAFKA-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1136:
--
Fix Version/s: 0.8.1
Add subAppend in Log4jAppender for generic usage
[
https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-404:
Affects Version/s: (was: 0.7.1)
0.8.1
When using chroot path, create
[
https://issues.apache.org/jira/browse/KAFKA-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829610#comment-13829610
]
Jie Huang commented on KAFKA-1136:
--
Thanks.
Add subAppend in Log4jAppender for generic
[
https://issues.apache.org/jira/browse/KAFKA-933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829627#comment-13829627
]
drunkedcat commented on KAFKA-933:
--
as 0.8.0-bete1, the following change will work:
[
https://issues.apache.org/jira/browse/KAFKA-933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829627#comment-13829627
]
drunkedcat edited comment on KAFKA-933 at 11/22/13 3:44 AM:
as
[
https://issues.apache.org/jira/browse/KAFKA-933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829627#comment-13829627
]
drunkedcat edited comment on KAFKA-933 at 11/22/13 3:54 AM:
as
Joe Stein created KAFKA-1141:
Summary: make changes to downloads for the archive old releases to
new old_releases folder
Key: KAFKA-1141
URL: https://issues.apache.org/jira/browse/KAFKA-1141
Project:
[
https://issues.apache.org/jira/browse/KAFKA-1141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein reassigned KAFKA-1141:
Assignee: Joe Stein
make changes to downloads for the archive old releases to new old_releases
[
https://issues.apache.org/jira/browse/KAFKA-1103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13829671#comment-13829671
]
Guozhang Wang commented on KAFKA-1103:
--
Wired. I already did a rebase and git diff
[
https://issues.apache.org/jira/browse/KAFKA-933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-933.
---
Resolution: Fixed
Thanks for the patch. Committed to trunk.
Hadoop example running DataGenerator causes
Hi,
I noticed Joel Koshy's update to the protocol guide wiki at
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
This sentence was added:
The broker allows only a single in-flight request per connection in order
to guarantee this ordering
Adding such a constraint
I can elaborate further on the wiki tomorrow. The term in-flight in my
edit is a bit incomplete. It refers to what's in-flight on the
broker-side for actual handling - that is what provides the ordering
guarantee. The client can continue to write requests to the socket
even while the broker is
30 matches
Mail list logo
