Here is the client side in ZK:
https://svn.apache.org/repos/asf/zookeeper/trunk/src/java/main/org/apache/zookeeper/client/ZooKeeperSaslClient.java
Note how they have a special Zookeeper request API that is used to
send the SASL bytes (e.g. see ZooKeeperSaslClient.sendSaslPacket).
This API follows
Hey Michael,
WRT question 2, I think for SASL you do need the mechanism information
but what I was talking about was the challenge/response byte[] that is
sent back and forth from the client to the server. My understanding is
that SASL gives you an api for the client and server to use to produce
t
Hey Jarek,
I agree with the importance of separating authentication and
authorization. The question is what concept of identity is sufficient
to pass through to the authorization layer? Just a "user name"? Or
perhaps you also need the ip the request originated from? Whatever
these would be it woul
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25886/#review55187
---
Thanks for the patch. A few comments below.
clients/src/main/java/
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14156057#comment-14156057
]
Neha Narkhede commented on KAFKA-1664:
--
+1 on providing a more meaningful error.
> K
[
https://issues.apache.org/jira/browse/KAFKA-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mayuresh Gharat updated KAFKA-1013:
---
Attachment: KAFKA-1013_2014-10-01_21:05:00.patch
> Modify existing tools as per the changes in
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/25944/
---
(Updated Oct. 2, 2014, 4:05 a.m.)
Review request for kafka.
Bugs: KAFKA-1013
[
https://issues.apache.org/jira/browse/KAFKA-1013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14156056#comment-14156056
]
Mayuresh Gharat commented on KAFKA-1013:
Updated reviewboard https://reviews.apach
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14156022#comment-14156022
]
Jun Rao commented on KAFKA-1664:
So, it seems that namespace doesn't exist. For tools, aut
I have a 5 node cluster with one Jab tracker and another namenode; zookeeper on
job tracker, namenode and a slave (of the three).
Can you advise me on what nodes should I use for installing kafka? I am looking
for at least 2 replications.
Ranjan
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155951#comment-14155951
]
Ricky Saltzer commented on KAFKA-1664:
--
Yes I've tried that as well, same problem.
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155908#comment-14155908
]
Jun Rao commented on KAFKA-1664:
Actually, namespace should only be included once in a ZK
[
https://issues.apache.org/jira/browse/KAFKA-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155903#comment-14155903
]
Jun Rao commented on KAFKA-1644:
Anton,
By letting FetchResponseSend to call FetchRespons
[
https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joel Koshy updated KAFKA-1647:
--
Assignee: Jiangjie Qin
> Replication offset checkpoints (high water marks) can be lost on hard kills
>
[
https://issues.apache.org/jira/browse/KAFKA-899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155742#comment-14155742
]
Jun Rao commented on KAFKA-899:
---
We started doing that classification in the new java produce
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155704#comment-14155704
]
Gwen Shapira commented on KAFKA-1664:
-
This happens with other high-level consumer cli
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155704#comment-14155704
]
Gwen Shapira edited comment on KAFKA-1664 at 10/1/14 10:43 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1664:
-
Reviewer: Neha Narkhede
> Kafka does not properly parse multiple ZK nodes with non-root chroot
> -
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1664:
-
Labels: newbie (was: )
> Kafka does not properly parse multiple ZK nodes with non-root chroot
> -
[
https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira reassigned KAFKA-1664:
---
Assignee: Gwen Shapira
> Kafka does not properly parse multiple ZK nodes with non-root chroot
Ricky Saltzer created KAFKA-1664:
Summary: Kafka does not properly parse multiple ZK nodes with
non-root chroot
Key: KAFKA-1664
URL: https://issues.apache.org/jira/browse/KAFKA-1664
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155678#comment-14155678
]
Guozhang Wang commented on KAFKA-1644:
--
Anton, I think Jun's not saying that there is
[
https://issues.apache.org/jira/browse/KAFKA-294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira resolved KAFKA-294.
Resolution: Fixed
With KAFKA-404 committed, this is resolved too.
> "Path length must be > 0" error
[
https://issues.apache.org/jira/browse/KAFKA-294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gwen Shapira updated KAFKA-294:
---
Fix Version/s: 0.8.2
> "Path length must be > 0" error during startup
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155647#comment-14155647
]
Guozhang Wang commented on KAFKA-1590:
--
[~jkreps] I agree that this would not be the
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155625#comment-14155625
]
Andrew Stein commented on KAFKA-1660:
-
Yes, {{close(timeout)}} is {{tryClose(timeout)}
Regarding question #1, I’m not sure I follow you, Joe: you’re proposing (I
think) that the API take a byte[], but what will be in that array? A
serialized certificate if the client authenticated via SSL and the
principal name (perhaps normalized) if the client authenticated via
Kerberos?
Regarding
I’m following the security proposal wiki page [1] and this discussion and I
would like to jump in with few points if I might :) Let me start by saying
that I like the material and the discussion here, good work!
I was part of the team who originally designed and worked on Sentry and I
wanted t
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155148#comment-14155148
]
Joe Stein commented on KAFKA-1494:
--
[~joshrosen] no worries about the clutter, it is just
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14155113#comment-14155113
]
Josh Rosen commented on KAFKA-1494:
---
Hi Joe,
Sorry for cluttering up this JIRA; I shoul
Hi Jonathan,
"Hadoop delegation tokens to enable MapReduce, Samza, or other frameworks
running in the Hadoop environment to access Kafka"
https://cwiki.apache.org/confluence/display/KAFKA/Security is on the list,
yup!
/***
Joe Stein
Founder, Principal Con
This is not nearly as deep as the discussion so far, but I did want to
throw this idea out there to make sure we¹ve thought about it.
The Kafka project should make sure that when deployed alongside a Hadoop
cluster from any major distributions that it can tie seamlessly into the
authentication and
[
https://issues.apache.org/jira/browse/KAFKA-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1662:
-
Description:
Finding issues doing the kafka release with permgen space
./gradlew releaseTarGzAll
ant:sca
[
https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1663:
-
Priority: Blocker (was: Major)
> Controller unable to shutdown after a soft failure
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1663:
-
Fix Version/s: 0.8.2
> Controller unable to shutdown after a soft failure
> --
Sriharsha Chintalapani created KAFKA-1663:
-
Summary: Controller unable to shutdown after a soft failure
Key: KAFKA-1663
URL: https://issues.apache.org/jira/browse/KAFKA-1663
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154882#comment-14154882
]
Jay Kreps commented on KAFKA-1660:
--
Gotcha, so if I understand close(time) is effectively
[
https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154877#comment-14154877
]
Jay Kreps commented on KAFKA-1661:
--
I guess the thinking was that test/ was for *our* tes
[
https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154870#comment-14154870
]
Sriharsha Chintalapani commented on KAFKA-1558:
---
[~nehanarkhede] working on
Andras,
Thanks for your feedback!
In my opinion programmatic message sending must work out of the box on the
first try, without any exceptions, warnings or the need for additional
configuration.
I'd be glad to support/contribute.
I agree that the behavior of the producer for the first message o
[
https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154867#comment-14154867
]
Neha Narkhede commented on KAFKA-1634:
--
[~jjkoshy] Thanks for the explanation. If ret
[
https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154862#comment-14154862
]
Neha Narkhede commented on KAFKA-1558:
--
[~sriharsha] Controller's inability to not sh
[
https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1661:
-
Reviewer: Neha Narkhede
Assignee: (was: Neha Narkhede)
[~Andras Hatvani] Feel free to thro
[
https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1661:
-
Labels: newbie test (was: test)
> Move MockConsumer and MockProducer from src/main to src/test
>
[
https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1661:
-
Priority: Trivial (was: Major)
> Move MockConsumer and MockProducer from src/main to src/test
> -
[
https://issues.apache.org/jira/browse/KAFKA-1660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154809#comment-14154809
]
Andrew Stein commented on KAFKA-1660:
-
Hi [~jkreps],
I don't think that this (the req
[
https://issues.apache.org/jira/browse/KAFKA-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein updated KAFKA-1662:
-
Labels: newbie (was: )
> gradle release issue permgen space
> --
>
>
Hi Bhavesh, I reproduced the issue you ran into
https://issues.apache.org/jira/browse/KAFKA-1662 if you want to throw up
your patch that would be great. Thanks!
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.st
Joe Stein created KAFKA-1662:
Summary: gradle release issue permgen space
Key: KAFKA-1662
URL: https://issues.apache.org/jira/browse/KAFKA-1662
Project: Kafka
Issue Type: Bug
Reporter
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154732#comment-14154732
]
Joe Stein edited comment on KAFKA-1494 at 10/1/14 12:31 PM:
Pl
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Joe Stein resolved KAFKA-1494.
--
Resolution: Won't Fix
Please make sure your advertised host name is set
https://kafka.apache.org/docume
Andras Hatvani created KAFKA-1661:
-
Summary: Move MockConsumer and MockProducer from src/main to
src/test
Key: KAFKA-1661
URL: https://issues.apache.org/jira/browse/KAFKA-1661
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154569#comment-14154569
]
Andras Hatvani commented on KAFKA-1494:
---
Josh, I've got a very similar Docker-based
[
https://issues.apache.org/jira/browse/KAFKA-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154518#comment-14154518
]
Josh Rosen commented on KAFKA-1494:
---
I'm able to reproduce a similar problem using Kafka
54 matches
Mail list logo
