[
https://issues.apache.org/jira/browse/KAFKA-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1861:
---
Attachment: KAFKA-1861.patch
Publishing kafka-client:test in order to utilize the helper
For the maven artifacts listed above, there doesn't seem to be any
distinction between rc1 or rc2, so is it assumed that this is release2
here?:
https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka_2.11/0.8.2.0/
Thanks!
Jason
On Wed, Jan 21, 2015 at 8:28 AM, Jun Rao
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francois Saint-Jacques updated KAFKA-1889:
--
Attachment: refactor-scripts-v1.patch
Refactor shell wrapper scripts
Hi Eliot,
I can't speak for the Kafka PMC, but as a general rule, if the code is
going to be contributed to the Kafka project itself, it must be
Apache-licensed. What you can do, and what many organizations do is release
code separately via a public Github account, which would allow you to
choose
[
https://issues.apache.org/jira/browse/KAFKA-1845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285979#comment-14285979
]
Andrii Biletskyi commented on KAFKA-1845:
-
In uploaded patch (KAFKA-1845.patch)
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286097#comment-14286097
]
Francois Saint-Jacques edited comment on KAFKA-1889 at 1/21/15 7:18 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286029#comment-14286029
]
Guozhang Wang commented on KAFKA-1782:
--
Jeff,
Sorry for getting late on this.
I
Francois Saint-Jacques created KAFKA-1889:
-
Summary: Refactor shell wrapper scripts
Key: KAFKA-1889
URL: https://issues.apache.org/jira/browse/KAFKA-1889
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexey Ozeritskiy updated KAFKA-1804:
-
Priority: Critical (was: Major)
Kafka network thread lacks top exception handler
[
https://issues.apache.org/jira/browse/KAFKA-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285995#comment-14285995
]
Manikumar Reddy commented on KAFKA-1861:
Can we include this simple patch to
[
https://issues.apache.org/jira/browse/KAFKA-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285990#comment-14285990
]
Manikumar Reddy commented on KAFKA-1861:
Created reviewboard
Hi Gwen,
Please see inline answers. I¹ll update them in the KIP as well.
Thanks.
Jiangjie (Becket) Qin
On 1/20/15, 6:39 PM, Gwen Shapira gshap...@cloudera.com wrote:
Thanks for the detailed document, Jiangjie. Super helpful.
Few questions:
1. You mention that A ConsumerRebalanceListener
[
https://issues.apache.org/jira/browse/KAFKA-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286162#comment-14286162
]
Sriharsha Chintalapani commented on KAFKA-1804:
---
[~jjkoshy] [~aozeritsky]
[
https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286158#comment-14286158
]
Jun Rao commented on KAFKA-1728:
Thanks for the patch for missing configs . +1 and
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30128/
---
Review request for kafka.
Bugs: KAFKA-1861
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30126/
---
Review request for kafka.
Bugs: KAFKA-1845
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286006#comment-14286006
]
Francois Saint-Jacques commented on KAFKA-1889:
---
I have multiple other
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francois Saint-Jacques updated KAFKA-1889:
--
Assignee: Francois Saint-Jacques
Status: Patch Available (was: Open)
[
https://issues.apache.org/jira/browse/KAFKA-1845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrii Biletskyi updated KAFKA-1845:
Status: Patch Available (was: Open)
KafkaConfig should use ConfigDef
[
https://issues.apache.org/jira/browse/KAFKA-1861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1861:
---
Assignee: Manikumar Reddy
Status: Patch Available (was: Open)
Publishing
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286097#comment-14286097
]
Francois Saint-Jacques commented on KAFKA-1889:
---
The second patch should
That's right. What's in maven staging is always for the latest RC being
voted. The stuff in maven staging will be promoted to maven central once
the vote passes.
Thanks,
Jun
On Wed, Jan 21, 2015 at 10:35 AM, Jason Rosenberg j...@squareup.com wrote:
For the maven artifacts listed above, there
[
https://issues.apache.org/jira/browse/KAFKA-1889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francois Saint-Jacques updated KAFKA-1889:
--
Attachment: refactor-scripts-v2.patch
Refactor shell wrapper scripts
[
https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1367:
-
Fix Version/s: 0.8.3
Broker topic metadata not kept in sync with ZooKeeper
This is the second candidate for release of Apache Kafka 0.8.2.0. There has
been some changes since the 0.8.2 beta release, especially in the new java
producer api and jmx mbean names. It would be great if people can test this
out thoroughly.
Release Notes for the 0.8.2.0 release
Ok, got it. Link is different from Release Candidate 1.
On Wed, Jan 21, 2015 at 10:01 PM, Jun Rao j...@confluent.io wrote:
Is it? You just need to navigate into org, then apache, then kafka, etc.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Manikumar Reddy ku...@nmsworks.co.in
wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/
---
(Updated Jan. 21, 2015, 4:42 p.m.)
Review request for kafka.
Summary
Is it? You just need to navigate into org, then apache, then kafka, etc.
Thanks,
Jun
On Wed, Jan 21, 2015 at 8:28 AM, Manikumar Reddy ku...@nmsworks.co.in
wrote:
Also Maven artifacts link is not correct
On Wed, Jan 21, 2015 at 9:50 PM, Jun Rao j...@confluent.io wrote:
Yes, will send out a
On Jan. 13, 2015, 10:32 p.m., Onur Karaman wrote:
clients/src/main/java/org/apache/kafka/clients/ClientRequest.java, lines
34-37
https://reviews.apache.org/r/27799/diff/2/?file=816201#file816201line34
It looks like you'd want to replace the attachment docs with new
callback
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/
---
(Updated Jan. 21, 2015, 4:47 p.m.)
Review request for kafka.
Bugs:
Hello,
I lead a group of developers at our company, ViaSat, who are building a set of
stream processing services on top of Kafka. We would very much like to open
source our work and become part of the Kafka “ecosystem” contributing back to
the community.
Our company is fairly new to
Also Maven artifacts link is not correct
On Wed, Jan 21, 2015 at 9:50 PM, Jun Rao j...@confluent.io wrote:
Yes, will send out a new email with the correct links.
Thanks,
Jun
On Wed, Jan 21, 2015 at 3:12 AM, Manikumar Reddy ku...@nmsworks.co.in
wrote:
All links are pointing to
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashish Kumar Singh updated KAFKA-1664:
--
Comment: was deleted
(was: Testing file
Yes, will send out a new email with the correct links.
Thanks,
Jun
On Wed, Jan 21, 2015 at 3:12 AM, Manikumar Reddy ku...@nmsworks.co.in
wrote:
All links are pointing to
https://people.apache.org/~junrao/kafka-0.8.2.0-candidate1/.
They should be
[
https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jay Kreps updated KAFKA-1760:
-
Attachment: KAFKA-1760_2015-01-21_08:42:20.patch
Implement new consumer client
[
https://issues.apache.org/jira/browse/KAFKA-1760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285851#comment-14285851
]
Jay Kreps commented on KAFKA-1760:
--
Updated reviewboard
Thanks for the answers. Much clearer now :)
Unrelated question: How do you test MirrorMaker (especially around data loss)?
I didn't see any unit-tests or integration tests in trunk.
Gwen
On Wed, Jan 21, 2015 at 9:55 AM, Jiangjie Qin j...@linkedin.com.invalid wrote:
Hi Gwen,
Please see inline
[
https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286326#comment-14286326
]
Chris Riccomini commented on KAFKA-1886:
IMO, the SimpleConsumer should at least
Hey Gwen,
Could we get the actual changes in that KIP? I.e. changes to metadata
request, changes to UpdateMetadataRequest, new configs and what will their
valid values be, etc. This kind of says that those things will change but
doesn't say what they will change to...
-Jay
On Mon, Jan 19, 2015
Currently it is a manual process. For functional test, I just setup two
Kafka clusters locally, mirror between them and keep producing data to one
of the cluster. Then try a hard kill / bounce mirror maker to see if
messages are lost in target cluster.
Jiangjie (Becket) Qin
On 1/21/15, 12:24 PM,
Hey guys,
A couple questions/comments:
1. The callback and user-controlled commit offset functionality is already
in the new consumer which we are working on in parallel. If we accelerated
that work it might help concentrate efforts. I admit this might take
slightly longer in calendar time but
[
https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286287#comment-14286287
]
Aditya A Auradkar commented on KAFKA-1886:
--
[~junrao] any thoughts?
Hello,
Congratulations to the folks behind kafka. Its has been a smooth ride
dealing with multi TB data when the same set up in JMS fell apart often.
Although I have been using kafka for more than a few days now, started
looking into the code base since yesterday and already have doubts at the
We have the new warning in 0.8.2.
I updated KIP-1 with the new plan:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1+-+Remove+support+of+request.required.acks
I'm waiting a day for additional discussion and if there are no
replies, I'll send the [VOTE] email.
Gwen
On Mon, Jan 19, 2015
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/29728/#review69107
---
Ship it!
Ship It!
- Guozhang Wang
On Jan. 8, 2015, 10:49 p.m.,
[
https://issues.apache.org/jira/browse/KAFKA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286676#comment-14286676
]
Jun Rao commented on KAFKA-1697:
From the discussion in the mailing list, we decided not
On Jan. 20, 2015, 4:35 p.m., Joel Koshy wrote:
core/src/main/scala/kafka/server/KafkaApis.scala, line 147
https://reviews.apache.org/r/27391/diff/8/?file=822017#file822017line147
I just realized that if we have a v0 or v1 request then we use the
offset manager default retention
[
https://issues.apache.org/jira/browse/KAFKA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286696#comment-14286696
]
Gwen Shapira commented on KAFKA-1697:
-
Updated!
remove code related to ack1 on the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30126/#review69063
---
core/src/main/scala/kafka/server/KafkaConfig.scala
[
https://issues.apache.org/jira/browse/KAFKA-1782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286491#comment-14286491
]
Jeff Holoman commented on KAFKA-1782:
-
Thank you for the feedback [~guozhang]. I will
[
https://issues.apache.org/jira/browse/KAFKA-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286651#comment-14286651
]
Jun Rao commented on KAFKA-1729:
[~jjkoshy], are you on track to complete the doc for the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27391/
---
(Updated Jan. 22, 2015, 12:43 a.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286662#comment-14286662
]
Guozhang Wang commented on KAFKA-1634:
--
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-1634:
-
Attachment: KAFKA-1634_2015-01-21_16:43:01.patch
Improve semantics of timestamp in
Posted a KIP for --re-balance for partition assignment in reassignment tool.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-6+-+New+reassignment+partition+logic+for+re-balancing
JIRA https://issues.apache.org/jira/browse/KAFKA-1792
While going through the KIP I thought of one thing from
Hi, created a KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-8+-+Decommission+a+broker
JIRA related https://issues.apache.org/jira/browse/KAFKA-1753
I took out the compatibility, migration section since this is new behavior.
If anyone can think of any we should add it back in.
[
https://issues.apache.org/jira/browse/KAFKA-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286734#comment-14286734
]
Guozhang Wang commented on KAFKA-1848:
--
Pushed to trunk, thanks.
Checking shutdown
[
https://issues.apache.org/jira/browse/KAFKA-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-1848.
--
Resolution: Fixed
Checking shutdown during each iteration of ZookeeperConsumerConnector
See https://builds.apache.org/job/Kafka-trunk/376/changes
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/#review69121
---
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286967#comment-14286967
]
Ewen Cheslack-Postava commented on KAFKA-1835:
--
[~ppearcy] these are easier
Created a KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-5+-+Broker+Configuration+Management
JIRA https://issues.apache.org/jira/browse/KAFKA-1786
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
Hi, created a KIP
https://cwiki.apache.org/confluence/display/KAFKA/KIP-4+-+Command+line+and+centralized+administrative+operations
JIRA https://issues.apache.org/jira/browse/KAFKA-1694
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source
Thanks for your comments Jay.
Quote Technically startup is not called from
multiple threads but the classes correctness should not depended on the
current usage so it should work correctly if it were. -- If this were a
requirement then one can see that many methods are NOT thread safe while
the
Hi Jay,
Thanks for comments. Please see inline responses.
Jiangjie (Becket) Qin
On 1/21/15, 1:33 PM, Jay Kreps jay.kr...@gmail.com wrote:
Hey guys,
A couple questions/comments:
1. The callback and user-controlled commit offset functionality is already
in the new consumer which we are working
Posted a KIP for IP Filtering:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-7+-+Security+-+IP+Filtering
Relevant JIRA:
https://issues.apache.org/jira/browse/KAFKA-1810
Appreciate any feedback.
Thanks
Jeff
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286816#comment-14286816
]
Paul Pearcy commented on KAFKA-1835:
Do I need to do anything else to get this in the
[
https://issues.apache.org/jira/browse/KAFKA-1810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286741#comment-14286741
]
Jeff Holoman commented on KAFKA-1810:
-
The current plan is to rework the configuration
[
https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14286763#comment-14286763
]
Jun Rao commented on KAFKA-1634:
I guess you mean rebasing KAFAK-1841, instead of
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27391/#review69106
---
Thanks for the patch. A few more comments.
On Jan. 22, 2015, 3:14 a.m., Jaikiran Pai wrote:
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java, line 253
https://reviews.apache.org/r/27799/diff/4/?file=828376#file828376line253
Hi Jay,
I think doing this unmuteAll in a finally block might be a good
Good point :)
I added the specifics of the new UpdateMetadataRequest, which is the
only protocol bump in this change.
Highlighted the broker and producer/consumer configuration changes,
added some example values and added the new zookeeper json.
Hope this makes things clearer.
On Wed, Jan 21,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/27799/#review69117
---
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Pearcy updated KAFKA-1835:
---
Attachment: KAFKA-1835.patch
Kafka new producer needs options to make blocking behavior explicit
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14287035#comment-14287035
]
Paul Pearcy commented on KAFKA-1835:
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-1835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14287042#comment-14287042
]
Paul Pearcy commented on KAFKA-1835:
Thanks Ewan. I created a review, added your
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/30158/
---
Review request for kafka.
Bugs: KAFKA-1835
[
https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-1728:
---
Attachment: missing-config-props-0.8.2.patch
Uploaded a patch to add missing config
78 matches
Mail list logo
