[
https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma reassigned KAFKA-2328:
--
Assignee: Ismael Juma
merge-kafka-pr.py script should not leave user in a detached branch
+1 (non-binding)
On Friday, July 17, 2015, Stevo Slavić ssla...@gmail.com wrote:
+1 (non-binding)
On Fri, Jul 17, 2015 at 12:26 PM, Ismael Juma ism...@juma.me.uk
javascript:; wrote:
Hi all,
I would like to start a vote on dropping support for Scala 2.9 for the
next
release. People
[
https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-1595:
---
Status: Patch Available (was: In Progress)
Mailing list thread:
On July 17, 2015, 4:26 a.m., Jiangjie Qin wrote:
Looks good to me.
Jiangjie Qin wrote:
Actually do we need to talk to Zookeeper every time? Can we read the data
from topic metadata cache directly?
Gwen Shapira wrote:
Good point, Jiangjie - looks like partitionFor is called
[
https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631432#comment-14631432
]
Ismael Juma commented on KAFKA-2328:
OK, I was wrong, there is code to restore the
+1 (non-binding)
On Fri, Jul 17, 2015 at 9:44 AM, Ashish Singh asi...@cloudera.com wrote:
+1 (non-binding)
On Friday, July 17, 2015, Stevo Slavić ssla...@gmail.com wrote:
+1 (non-binding)
On Fri, Jul 17, 2015 at 12:26 PM, Ismael Juma ism...@juma.me.uk
javascript:; wrote:
Hi all,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36570/
---
Review request for kafka.
Bugs: KAFKA-2337
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631468#comment-14631468
]
Grant Henke commented on KAFKA-2337:
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke updated KAFKA-2337:
---
Status: Patch Available (was: In Progress)
Verify that metric names will not collide when creating
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke updated KAFKA-2337:
---
Attachment: KAFKA-2337.patch
Verify that metric names will not collide when creating new topics
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631474#comment-14631474
]
Grant Henke commented on KAFKA-2337:
This patch:
- Checks all topic creation including
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630836#comment-14630836
]
Ashish K Singh commented on KAFKA-2345:
---
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2345:
--
Attachment: KAFKA-2345.patch
Attempt to delete a topic already marked for deletion throws
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2345:
--
Status: Patch Available (was: Open)
Attempt to delete a topic already marked for deletion
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/
---
Review request for kafka.
Bugs: KAFKA-2345
Hi there,
I just added a KIP for a 'conditional publish' operation: a simple
CAS-like mechanism for the Kafka producer. The wiki page is here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-27+-+Conditional+Publish
And there's some previous discussion on the ticket and the users list:
[
https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630870#comment-14630870
]
Ben Kirwin commented on KAFKA-2260:
---
Opened a KIP for this here:
[
https://issues.apache.org/jira/browse/KAFKA-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Chen reassigned KAFKA-2339:
---
Assignee: Timothy Chen
broker becomes unavailable if bad data is passed through the
Asano Ryohei created KAFKA-2346:
---
Summary: modified typo api.html in 0.8.2 and 0.8.3
Key: KAFKA-2346
URL: https://issues.apache.org/jira/browse/KAFKA-2346
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630894#comment-14630894
]
Ismael Juma commented on KAFKA-2344:
To avoid confusion since that wiki age has a lot
[
https://issues.apache.org/jira/browse/KAFKA-2346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Asano Ryohei updated KAFKA-2346:
Attachment: KAFKA_api_typo-0.8.3.patch
KAFKA_api_typo-0.8.2.patch
modified typo
See https://builds.apache.org/job/KafkaPreCommit/155/changes
Changes:
[cshapi] KAFKA-2324; Update to Scala 2.11.7
--
[...truncated 1137 lines...]
kafka.consumer.ZookeeperConsumerConnectorTest testLeaderSelectionForPartition
PASSED
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630887#comment-14630887
]
Ismael Juma commented on KAFKA-2344:
Good point about the reviewers. I noticed that
[
https://issues.apache.org/jira/browse/KAFKA-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630981#comment-14630981
]
Timothy Chen commented on KAFKA-2339:
-
Somehow I can't produce this with kafkacat and
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14630874#comment-14630874
]
Guozhang Wang commented on KAFKA-1835:
--
Hmm, so although partitionsFor() returns you
[
https://issues.apache.org/jira/browse/KAFKA-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631048#comment-14631048
]
Ismael Juma commented on KAFKA-2203:
I just did a `gradlew build` with JDK 8u60 EA and
+1 (non-binding)
On Friday, July 17, 2015, Grant Henke ghe...@cloudera.com wrote:
+1 (non-binding)
On Fri, Jul 17, 2015 at 9:44 AM, Ashish Singh asi...@cloudera.com
javascript:; wrote:
+1 (non-binding)
On Friday, July 17, 2015, Stevo Slavić ssla...@gmail.com javascript:;
wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36570/
---
(Updated July 17, 2015, 4:17 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-2328:
---
Status: Patch Available (was: Open)
Looks like definite bug, PR fixes it. [~gwenshap] or
[
https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631502#comment-14631502
]
Jiangjie Qin commented on KAFKA-2260:
-
[~bkirwi] The question 1 I had is actually for
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36570/#review92092
---
core/src/main/scala/kafka/common/Topic.scala (lines 53 - 54)
On July 17, 2015, 4:01 p.m., Edward Ribeiro wrote:
core/src/main/scala/kafka/common/Topic.scala, line 64
https://reviews.apache.org/r/36570/diff/1/?file=1014515#file1014515line64
*Maybe* this method name could be renamed to 'collide' to make it more
like a verb instead of a
+1 (binding)
On Fri, Jul 17, 2015 at 8:33 AM, Brock Noland br...@apache.org wrote:
+1 (non-binding)
On Friday, July 17, 2015, Grant Henke ghe...@cloudera.com wrote:
+1 (non-binding)
On Fri, Jul 17, 2015 at 9:44 AM, Ashish Singh asi...@cloudera.com
javascript:; wrote:
+1
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/84
KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached
branch
The right command to get the branch name is `git rev-parse --abbrev-ref
HEAD` instead of `git rev-parse HEAD`. The
[
https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631543#comment-14631543
]
ASF GitHub Bot commented on KAFKA-2328:
---
GitHub user ijuma opened a pull request:
On July 17, 2015, 4:01 p.m., Edward Ribeiro wrote:
core/src/main/scala/kafka/common/Topic.scala, line 64
https://reviews.apache.org/r/36570/diff/1/?file=1014515#file1014515line64
*Maybe* this method name could be renamed to 'collide' to make it more
like a verb instead of a
[
https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631512#comment-14631512
]
Jay Kreps commented on KAFKA-2260:
--
[~yasuhiro.matsuda] had a good variation on this
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35867/#review92078
---
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/#review92088
---
Ship it!
Ship It!
- Sriharsha Chintalapani
On July 17, 2015,
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631509#comment-14631509
]
Jiangjie Qin commented on KAFKA-1835:
-
I am thinking partitionsFor() will not use
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36570/#review92089
---
core/src/main/scala/kafka/common/Topic.scala (line 64)
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/#review92090
---
[
https://issues.apache.org/jira/browse/KAFKA-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1901:
--
Status: In Progress (was: Patch Available)
Move Kafka version to be generated in code by build
+1 (non-binding)
On Fri, Jul 17, 2015 at 12:26 PM, Ismael Juma ism...@juma.me.uk wrote:
Hi all,
I would like to start a vote on dropping support for Scala 2.9 for the next
release. People seemed to be in favour of the idea in previous discussions:
*
[
https://issues.apache.org/jira/browse/KAFKA-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631105#comment-14631105
]
Stevo Slavic commented on KAFKA-2203:
-
On a clean clone of trunk, with gradle 2.5 and
[
https://issues.apache.org/jira/browse/KAFKA-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631105#comment-14631105
]
Stevo Slavic edited comment on KAFKA-2203 at 7/17/15 9:50 AM:
--
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/83
KAFKA-1595; Remove deprecated and slower scala JSON parser
Tested that we only use Jackson methods introduced in 2.0 in the main
codebase by compiling it with the older version locally. We use a
[
https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631210#comment-14631210
]
ASF GitHub Bot commented on KAFKA-1595:
---
GitHub user ijuma opened a pull request:
[
https://issues.apache.org/jira/browse/KAFKA-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631114#comment-14631114
]
Ismael Juma commented on KAFKA-2203:
I was planning to start a [VOTE] thread in the
Hi all,
I would like to start a vote on dropping support for Scala 2.9 for the next
release. People seemed to be in favour of the idea in previous discussions:
* http://search-hadoop.com/m/uyzND1uIW3k2fZVfU1
* http://search-hadoop.com/m/uyzND1KMLNK11Rmo72
Summary of why we should drop Scala
[
https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-1595:
---
Attachment: (was: KAFKA-1595.patch)
Remove deprecated and slower scala JSON parser from
[
https://issues.apache.org/jira/browse/KAFKA-2203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631106#comment-14631106
]
Ismael Juma commented on KAFKA-2203:
Stevo, Scala 2.9.x doesn't support Java 8. That's
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma reassigned KAFKA-2344:
--
Assignee: Ismael Juma
Improvements for the pr-merge tool
--
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631564#comment-14631564
]
Ismael Juma commented on KAFKA-2344:
I renamed the JIRA title, I hope you don't mind.
+1 (binding)
On Fri, Jul 17, 2015 at 3:26 AM, Ismael Juma ism...@juma.me.uk wrote:
Hi all,
I would like to start a vote on dropping support for Scala 2.9 for the next
release. People seemed to be in favour of the idea in previous discussions:
* http://search-hadoop.com/m/uyzND1uIW3k2fZVfU1
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/#review92106
---
Ship it!
- Gwen Shapira
On July 17, 2015, 5:21 p.m., Ashish
On July 17, 2015, 4:26 a.m., Jiangjie Qin wrote:
Looks good to me.
Jiangjie Qin wrote:
Actually do we need to talk to Zookeeper every time? Can we read the data
from topic metadata cache directly?
Gwen Shapira wrote:
Good point, Jiangjie - looks like partitionFor is called
Ick. It seemed to work locally. I'm checking what went wrong.
Let me know if you want a revert.
On Fri, Jul 17, 2015 at 10:39 AM, Apache Jenkins Server
jenk...@builds.apache.org wrote:
See https://builds.apache.org/job/KafkaPreCommit/156/changes
Changes:
[cshapi] KAFKA-2345; Attempt to
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-2344:
---
Summary: kafka-merge-pr should support reviewers in commit message (was:
Improvements for the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/
---
(Updated July 17, 2015, 5:21 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631618#comment-14631618
]
Ashish K Singh commented on KAFKA-2345:
---
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2345:
--
Attachment: KAFKA-2345_2015-07-17_10:20:55.patch
Attempt to delete a topic already marked for
I like this feature, it reminds me of conditional updates in zookeeper. I'm not
sure if it'd be best to have some mechanism for fencing rather than a
conditional write like you're proposing. The reason I'm saying this is that the
conditional write applies to requests individually, while it
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631645#comment-14631645
]
Gwen Shapira commented on KAFKA-2345:
-
Thanks for the patch [~singhashish] and for the
On July 17, 2015, 4:26 a.m., Jiangjie Qin wrote:
Looks good to me.
Jiangjie Qin wrote:
Actually do we need to talk to Zookeeper every time? Can we read the data
from topic metadata cache directly?
Gwen Shapira wrote:
Good point, Jiangjie - looks like partitionFor is called
[
https://issues.apache.org/jira/browse/KAFKA-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631614#comment-14631614
]
Gwen Shapira commented on KAFKA-2344:
-
Good with me [~ijuma].
The JIRA issue was my
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36565/#review92105
---
[
https://issues.apache.org/jira/browse/KAFKA-2345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-2345:
Resolution: Fixed
Reviewer: Gwen Shapira
Fix Version/s: 0.8.3
Status:
See https://builds.apache.org/job/KafkaPreCommit/156/changes
Changes:
[cshapi] KAFKA-2345; Attempt to delete a topic already marked for deletion
throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha
Chintalapani and Ismael Juma
On July 17, 2015, 4:05 p.m., Edward Ribeiro wrote:
core/src/main/scala/kafka/common/Topic.scala, lines 53-54
https://reviews.apache.org/r/36570/diff/1/?file=1014515#file1014515line53
This method name is sort of a misnomer is a it is checking for special
characters that could lead
On July 17, 2015, 4:01 p.m., Edward Ribeiro wrote:
core/src/main/scala/kafka/common/Topic.scala, line 64
https://reviews.apache.org/r/36570/diff/1/?file=1014515#file1014515line64
*Maybe* this method name could be renamed to 'collide' to make it more
like a verb instead of a
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631525#comment-14631525
]
Grant Henke commented on KAFKA-2337:
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke updated KAFKA-2337:
---
Attachment: KAFKA-2337_2015-07-17_11:17:30.patch
Verify that metric names will not collide when
[
https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631772#comment-14631772
]
Aditya Auradkar commented on KAFKA-2205:
[~junrao] Another patch ready!
+1 (binding)
On 17 July 2015 at 10:06, Gwen Shapira gshap...@cloudera.com wrote:
+1 (binding)
On Fri, Jul 17, 2015 at 3:26 AM, Ismael Juma ism...@juma.me.uk wrote:
Hi all,
I would like to start a vote on dropping support for Scala 2.9 for the next
release. People seemed to be in favour of
See https://builds.apache.org/job/KafkaPreCommit/157/changes
Changes:
[cshapi] Adding a file missed while committing KAFKA-2345
--
[...truncated 797 lines...]
kafka.log.OffsetMapTest testBasicValidation PASSED
kafka.log.LogManagerTest
On July 17, 2015, 4:43 a.m., Jun Rao wrote:
core/src/main/scala/kafka/server/ConfigHandler.scala, lines 64-65
https://reviews.apache.org/r/34554/diff/5/?file=1011630#file1011630line64
Could we just use Pool?
Nice.. didn't know about that util.
- Aditya
[
https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631699#comment-14631699
]
Aditya A Auradkar commented on KAFKA-2205:
--
Updated reviewboard
See https://builds.apache.org/job/Kafka-trunk/549/changes
Changes:
[cshapi] KAFKA-2345; Attempt to delete a topic already marked for deletion
throws ZkNodeExistsException; patched by Ashish Singh; reviewed by Sriharsha
Chintalapani and Ismael Juma
[cshapi] Adding a file missed while
With more of Kafka's development moving to Github is there any interest in
creating a Gitter chat room?
I think it could be useful to have a place to chat that is associated with
the Kafka repo. Note that we do currently have an IRC channel, but from my
experience its a ghost town.
I am also
+1, will be helpful.
On Fri, Jul 17, 2015 at 11:28 AM, Grant Henke ghe...@cloudera.com wrote:
With more of Kafka's development moving to Github is there any interest in
creating a Gitter chat room?
I think it could be useful to have a place to chat that is associated with
the Kafka repo.
my bad, I missed a file while committing.
I did a trivial commit with the missing file and I think the build
looks ok now.
On Fri, Jul 17, 2015 at 10:42 AM, Gwen Shapira csh...@gmail.com wrote:
Ick. It seemed to work locally. I'm checking what went wrong.
Let me know if you want a revert.
It's a bit easy for this to happen with the patch workflow. The GitHub one
via the merge script fixes it nicely. There are a couple of improvements
that need to be done and then I will start a vote on switching to it.
Hopefully early next week.
Ismael
On 17 Jul 2015 18:55, Gwen Shapira
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34554/
---
(Updated July 17, 2015, 6:14 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631694#comment-14631694
]
Aditya A Auradkar commented on KAFKA-2205:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34554/
---
(Updated July 17, 2015, 6:14 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2205:
-
Attachment: KAFKA-2205_2015-07-17_11:14:26.patch
Generalize TopicConfigManager to handle
[
https://issues.apache.org/jira/browse/KAFKA-1595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631700#comment-14631700
]
Gwen Shapira commented on KAFKA-1595:
-
[~ijuma] - I'll be happy to review, but can't
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34554/
---
(Updated July 17, 2015, 6:18 p.m.)
Review request for kafka, Joel Koshy and
[
https://issues.apache.org/jira/browse/KAFKA-2205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2205:
-
Attachment: KAFKA-2205_2015-07-17_11:18:31.patch
Generalize TopicConfigManager to handle
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34554/
---
(Updated July 17, 2015, 6:20 p.m.)
Review request for kafka, Joel Koshy and
If we have 2 producers producing to a partition, they can be out of order,
then how does one producer know what offset to expect as it does not
interact with other producer?
Can you give an example flow that explains how it works with single
producer and with multiple producers?
Thanks,
Hi,
We've been using the new Kafka Metrics within Voldemort for a little while
now, and we have made some improvements to the library that you might like
to copy back into Kafka proper. You can view the changes that went in after
we forked here:
https://github.com/tehuti-io/tehuti/commits/master
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36578/
---
Review request for kafka.
Bugs: KAFKA-2338
[
https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Edward Ribeiro updated KAFKA-2338:
--
Attachment: KAFKA-2338.patch
Warn users if they change max.message.bytes that they also need
[
https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631784#comment-14631784
]
Edward Ribeiro commented on KAFKA-2338:
---
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14631785#comment-14631785
]
Edward Ribeiro commented on KAFKA-2338:
---
Hi [~ewencp], as this my first official
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36590/
---
Review request for kafka.
Bugs: KAFKA-2275
[
https://issues.apache.org/jira/browse/KAFKA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish K Singh updated KAFKA-2275:
--
Status: Patch Available (was: Open)
Add a ListTopics() API to the new consumer
[
https://issues.apache.org/jira/browse/KAFKA-2275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14632137#comment-14632137
]
Ashish K Singh commented on KAFKA-2275:
---
Created reviewboard
1 - 100 of 145 matches
Mail list logo
