[
https://issues.apache.org/jira/browse/KAFKA-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Karamanov updated KAFKA-1620:
---
Attachment: 0002-KAFKA-1620-Make-kafka-api-protocol-implementation-pu.patch
Not really. I
GitHub user LantaoJin opened a pull request:
https://github.com/apache/kafka/pull/33
KAFKA-1635: Fixed incorrect java doc of makeLeaders() in ReplicaManager
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/LantaoJin/kafka
[
https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135135#comment-14135135
]
ASF GitHub Bot commented on KAFKA-1635:
---
GitHub user LantaoJin opened a pull
[
https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lantao Jin updated KAFKA-1635:
--
Priority: Trivial (was: Minor)
Java doc of makeLeaders in ReplicaManager is wrong
[
https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lantao Jin updated KAFKA-1635:
--
Description:
ReplicaManager have an incorrect java doc. The overview of function
makeLeaders() is the
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135561#comment-14135561
]
Nicolae Marasoiu commented on KAFKA-1282:
-
Hi, I have not made any patch yet, I
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135561#comment-14135561
]
Nicolae Marasoiu edited comment on KAFKA-1282 at 9/16/14 3:00 PM:
[
https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135588#comment-14135588
]
Balaji Seshadri commented on KAFKA-1618:
ok if user doesn't give any port i will
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-1490 started by Ivan Lyutov.
--
remove gradlew initial setup output from source distribution
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25697/
---
Review request for kafka.
Bugs: KAFKA-1490
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Lyutov updated KAFKA-1490:
---
Attachment: KAFKA-1490.patch
remove gradlew initial setup output from source distribution
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135703#comment-14135703
]
Ivan Lyutov commented on KAFKA-1490:
I've deleted the gradlew output jar file and left
Hi,
I was just reading the recent changes to:
https://cwiki.apache.org/confluence/display/KAFKA/Security after getting
off a call about Kafka security and how we are jumping through hoops --
like having PGP keys on the consumers and producers to get around the lack
of SSL support. Did the meeting
Hi Jacky,
Could you elaborate a bit on your use cases, like why you want to manually
truncate logs? Kafka provide a set of configs for data retention based on
data size and time (for example maintaining as much as 100 GB or up to 7
days of old data), would that be sufficient to you?
Guozhang
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135765#comment-14135765
]
Joe Stein commented on KAFKA-1490:
--
it is our problem, we need to resolve this we
Hi Andrew, yes the meeting took place and we plan to-do it every two weeks
(same bat time, same bat channel) moving forward.
In attendance was Michael Herstine (LinkedIn), Arvind Mani (LinkedIn), Gwen
Shapira (Cloudera) and myself.
Gwen updated the wiki after our discussion. Basically we are
[
https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135811#comment-14135811
]
Sriharsha Chintalapani commented on KAFKA-1558:
---
Thanks [~junrao]
Case 2
Hi Joe,
I am interested in joining the efforts. I went through apache
storm security with kerberos so I can bring some of that
experience into the discussion.
Thanks,
Harsha
On Tue, Sep 16, 2014, at 10:37 AM, Joe Stein wrote:
Hi Andrew, yes the meeting took place and we
cool, I just added you to the invite
On Tue, Sep 16, 2014 at 10:57 AM, Harsha ka...@harsha.io wrote:
Hi Joe,
I am interested in joining the efforts. I went through apache
storm security with kerberos so I can bring some of that
experience into the discussion.
Thanks,
btw. I think we barely mention support of delegation tokens to allow
accessing Kafka from MR jobs, Storm, Samza, etc.
Does it sound in scope for next week's agenda?
Gwen
On Tue, Sep 16, 2014 at 10:59 AM, Joe Stein joe.st...@stealth.ly wrote:
cool, I just added you to the invite
On Tue, Sep
Hi All,
Do we have any ballpark date on the release of 0.8.1.2 or 0.8.2.
Thanks,
Harsha
On Thu, Sep 11, 2014, at 03:53 PM, Jay Kreps wrote:
I agree that a beta for 0.8.2 would be useful. It would also be good
to get it in production at LinkedIn before the final version.
Sorry about
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25703/
---
Review request for kafka.
Bugs: KAFKA-1490
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Lyutov updated KAFKA-1490:
---
Attachment: KAFKA-1490-2.patch
Ok, I applied the patch which replays the functionality from Samza.
Laurie Turner created KAFKA-1636:
Summary: High CPU in very active environment
Key: KAFKA-1636
URL: https://issues.apache.org/jira/browse/KAFKA-1636
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135928#comment-14135928
]
Ivan Lyutov commented on KAFKA-1490:
https://reviews.apache.org/r/25697/
remove
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135928#comment-14135928
]
Ivan Lyutov edited comment on KAFKA-1490 at 9/16/14 6:41 PM:
-
Joe, can you add me to it as well? We obviously have some interest in the
discussion over here :)
-Todd
On 9/16/14, 10:59 AM, Joe Stein joe.st...@stealth.ly wrote:
cool, I just added you to the invite
On Tue, Sep 16, 2014 at 10:57 AM, Harsha ka...@harsha.io wrote:
Hi Joe,
I am
Yup!
On Tue, Sep 16, 2014 at 11:09 AM, Gwen Shapira gshap...@cloudera.com
wrote:
btw. I think we barely mention support of delegation tokens to allow
accessing Kafka from MR jobs, Storm, Samza, etc.
Does it sound in scope for next week's agenda?
Gwen
On Tue, Sep 16, 2014 at 10:59 AM, Joe
=8^)
done
On Tue, Sep 16, 2014 at 11:43 AM, Todd Palino tpal...@linkedin.com.invalid
wrote:
Joe, can you add me to it as well? We obviously have some interest in the
discussion over here :)
-Todd
On 9/16/14, 10:59 AM, Joe Stein joe.st...@stealth.ly wrote:
cool, I just added you to the
Same here.
Thanks,
Joel
On Tue, Sep 16, 2014 at 06:43:22PM +, Todd Palino wrote:
Joe, can you add me to it as well? We obviously have some interest in the
discussion over here :)
-Todd
On 9/16/14, 10:59 AM, Joe Stein joe.st...@stealth.ly wrote:
cool, I just added you to the
[
https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14135957#comment-14135957
]
Joel Koshy commented on KAFKA-1499:
---
Sorry you are right - I mixed up the two. For some
Hi Joe,
I am certainly interested. Can you please add me to the invite.
Thanks,
Andrew
On Tue, Sep 16, 2014 at 11:37 AM, Joe Stein joe.st...@stealth.ly wrote:
Hi Andrew, yes the meeting took place and we plan to-do it every two weeks
(same bat time, same bat channel) moving forward.
In
done
On Tue, Sep 16, 2014 at 11:48 AM, Andrew Psaltis psaltis.and...@gmail.com
wrote:
Hi Joe,
I am certainly interested. Can you please add me to the invite.
Thanks,
Andrew
On Tue, Sep 16, 2014 at 11:37 AM, Joe Stein joe.st...@stealth.ly wrote:
Hi Andrew, yes the meeting took place and
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25703/
---
(Updated Сен. 16, 2014, 6:54 п.п.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1490:
-
Reviewer: Joe Stein
remove gradlew initial setup output from source distribution
Same here
On Sep 16, 2014, at 11:51, Joe Stein joe.st...@stealth.ly wrote:
done
On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy jjkosh...@gmail.com wrote:
Same here.
Thanks,
Joel
On Tue, Sep 16, 2014 at 06:43:22PM +, Todd Palino wrote:
Joe, can you add me to it as well? We
[
https://issues.apache.org/jira/browse/KAFKA-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1622:
-
Reviewer: Joe Stein
project shouldn't require signing to build
Same here, please.
- Rob
On Sep 16, 2014, at 12:58 PM, Steve Morin steve.mo...@gmail.com wrote:
Same here
On Sep 16, 2014, at 11:51, Joe Stein joe.st...@stealth.ly wrote:
done
On Tue, Sep 16, 2014 at 11:46 AM, Joel Koshy jjkosh...@gmail.com wrote:
Same here.
Thanks,
Joel
done, done
On Tue, Sep 16, 2014 at 12:23 PM, Robert Withers robert.w.with...@gmail.com
wrote:
Same here, please.
- Rob
On Sep 16, 2014, at 12:58 PM, Steve Morin steve.mo...@gmail.com wrote:
Same here
On Sep 16, 2014, at 11:51, Joe Stein joe.st...@stealth.ly wrote:
done
On
Oops, n/m for now, I'm non-local.
Thanks,
- Rob
On Sep 16, 2014, at 1:23 PM, Robert Withers robert.w.with...@gmail.com
wrote:
Same here, please.
- Rob
On Sep 16, 2014, at 12:58 PM, Steve Morin steve.mo...@gmail.com wrote:
Same here
On Sep 16, 2014, at 11:51, Joe Stein
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282_the_ultimate,_close_max_one_per_select.patch
Attached patch: every select
[
https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayuresh Gharat updated KAFKA-1610:
---
Attachment: KAFKA-1610_2014-09-16_13:08:17.patch
Local modifications to collections
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25136/
---
(Updated Sept. 16, 2014, 8:08 p.m.)
Review request for kafka.
Bugs:
[
https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136111#comment-14136111
]
Mayuresh Gharat commented on KAFKA-1610:
Updated reviewboard
Hey Joe,
Can you add me, Jun, and Neha too.
-Jay
On Tue, Sep 16, 2014 at 10:37 AM, Joe Stein joe.st...@stealth.ly wrote:
Hi Andrew, yes the meeting took place and we plan to-do it every two weeks
(same bat time, same bat channel) moving forward.
In attendance was Michael Herstine
[
https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136206#comment-14136206
]
Jay Kreps commented on KAFKA-1618:
--
I think the problem with a default port is that yes,
yup, yup, yup | done, done, done
On Tue, Sep 16, 2014 at 1:54 PM, Jay Kreps jay.kr...@gmail.com wrote:
Hey Joe,
Can you add me, Jun, and Neha too.
-Jay
On Tue, Sep 16, 2014 at 10:37 AM, Joe Stein joe.st...@stealth.ly wrote:
Hi Andrew, yes the meeting took place and we plan to-do it
[
https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136220#comment-14136220
]
Balaji Seshadri commented on KAFKA-1618:
I agree with you [~jkreps] and
Hi,
So maybe I should I should have asked the Q explicitly:
Could we commit the patch from
https://issues.apache.org/jira/browse/KAFKA-1481 now that, I hope, it's
clear what problems the current MBean names can cause?
Thanks,
Otis
--
Monitoring * Alerting * Anomaly Detection * Centralized Log
[
https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136314#comment-14136314
]
Stevo Slavic commented on KAFKA-1624:
-
If I'm not mistaken, this error is caused by
[
https://issues.apache.org/jira/browse/KAFKA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krzysztof Szafrański updated KAFKA-1123:
Attachment: KAFKA-1123_v2.patch
Broker IPv6 addresses parsed incorrectly
[
https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayuresh Gharat updated KAFKA-1610:
---
Attachment: KAFKA-1610_2014-09-16_15:23:27.patch
Local modifications to collections
[
https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136372#comment-14136372
]
Mayuresh Gharat commented on KAFKA-1610:
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25136/
---
(Updated Sept. 16, 2014, 10:23 p.m.)
Review request for kafka.
Bugs:
We observe that when a broker is down, Producer.send() can get into a state
where it will block forever, even when using the async producer.
When a Producer first sends data, it fetches topic metadata from the broker
cluster. To do this, it shuffles the list of hosts in the cluster, then
Amir Malekpour created KAFKA-1637:
-
Summary: SimpleConsumer.fetchOffset returns wrong error code
Key: KAFKA-1637
URL: https://issues.apache.org/jira/browse/KAFKA-1637
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amir Malekpour updated KAFKA-1637:
--
Summary: SimpleConsumer.fetchOffset returns wrong error code when no offset
exists for
[
https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Amir Malekpour updated KAFKA-1637:
--
Description:
This concerns Kafka's Offset Fetch API:
According to Kafka's current
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136767#comment-14136767
]
Jun Rao commented on KAFKA-1282:
Did you do ./gradlew jar first?
Disconnect idle socket
Jack,
If the broker is down, channel.connect() should throw an IOException,
instead of blocking forever. In your case, is the broker host down? In that
case, the connect call will likely wait for the default tcp connection
timeout, which is 8+ mins.
Thanks,
Jun
On Tue, Sep 16, 2014 at 5:43 PM,
[
https://issues.apache.org/jira/browse/KAFKA-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-1635.
Resolution: Fixed
Fix Version/s: 0.8.2
Assignee: Lantao Jin (was: Neha Narkhede)
Thanks
See https://builds.apache.org/job/Kafka-trunk/267/changes
Changes:
[junrao] trivial change to javadoc for makeLeaders(); patched by Lantao Jin
--
[...truncated 2717 lines...]
at sun.nio.ch.Net.bind(Native Method)
at
[
https://issues.apache.org/jira/browse/KAFKA-1620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14136817#comment-14136817
]
Anton Karamanov commented on KAFKA-1620:
Yes, it is actually one of the primary
63 matches
Mail list logo
